def close.stream

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

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

57def close.stream(
58  file: File,
59  +directory: String,
60  stream: BackupCursor.Stream,
61  error: U32 & String
62) -> IO(Result<&1, &1, BackupIo.Error, Unit>):
63  match stream:
64    case BackupCursor.Stream{_, Some{cursor}, _, _, _, _, _, _, _}:
65      close.source(file, directory, cursor, error)
66    case BackupCursor.Stream{_, None{}, _, _, _, _, _, _, _}:
67      BackupIo.close.failed(file, directory, error)