def loop.abort

mylsm-lsm-store@0.6.0.1 · src/transfer/BackupCursorIo.bend:195

import Base
import mylsm-lsm-store@0.6.0.1/src/transfer/BackupCursor.bend as BackupCursor
import mylsm-lsm-store@0.6.0.1/src/transfer/BackupIo.bend as BackupIo

195def loop.abort(
196  +temporary: String,
197  state: State
198) -> IO(Result<&1, &1, BackupIo.Error, Unit>):
199  match state:
200    case Need{file, stream}:
201      close.resource.stream(file, temporary, stream)
202    case Output{file, step}:
203      match step:
204        case BackupCursor.Failure{cursor, error}:
205          close.error(file, temporary, cursor, error)
206        case BackupCursor.Chunk{stream, _}:
207          close.resource.stream(file, temporary, stream)
208        case BackupCursor.Continue{stream}:
209          close.resource.stream(file, temporary, stream)
210        case BackupCursor.End{}:
211          close.resource(file, temporary, None{})
212    case Written{pair, stream}:
213      match pair:
214        case (file, Fail{error}): close.stream(file, temporary, stream, error)
215        case (file, Done{Unit{}}):
216          close.resource.stream(file, temporary, stream)