def source.step

mylsm-lsm-store@0.6.0.1 · src/transfer/BackupOwnerCursorIo.bend:134

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

134def source.step(
135  source: OwnerSource,
136  stream: BackupCursor.Stream,
137  file: File
138) -> IO(State):
139  match stream:
140    case BackupCursor.Stream{BackupCursor.CursorBlocks{}, _, _, _, _, _, _, _, _}:
141      source.step.cloned(file, stream, source.clone(source))
142    case _:
143      IO.pure(State, Output{file, source,
144        BackupCursor.advance.owner(stream, CursorCodec.CursorEnd{})})