def finish
mylsm-lsm-store@0.6.0.1 · src/transfer/BackupCursor.bend:282
import mylsm-lsm-store@0.6.0.1/src/transfer/BackupCursor.bend as BackupCursor
import Base
import mylsm-lsm-store@0.6.0.1/src/transfer/Backup.bend as Backup
282
283def finish(stream: Stream) -> Step:
284 match stream:
285 case Stream{CursorBlocks{}, cursor, pending, pending_count, seen, expected,
286 entry_count, block_count, block_index}:
287 finish.copied(cursor, pending, pending_count,
288 Backup.nat.duplicate.pair(seen),
289 Backup.nat.duplicate.pair(expected),
290 entry_count, block_count, block_index)
291 case Stream{_, cursor, _, _, _, _, _, _, _}: Failure{cursor, Backup.CodecFailure{}}