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# Rejects early cursor end; emits a final partial block before the footer.
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{}}

Uses (6)

Used by (2)