def stream.blocks.consumed

mylsm-lsm-store@0.6.0.1 · src/SstFile.bend:1217

import Base
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

1217# Requires the block parser to consume its complete input slice.
1218def stream.blocks.consumed(
1219  pair: Bytes.Cursor & U32,
1220  state: BlockStreamState,
1221  block: ParsedBlock
1222) -> Result<&1, &1, Error, BlockStreamOutput>:
1223  match pair:
1224    case (_, remaining):
1225      stream.blocks.complete(state, block, U32.is_eq(remaining, 0))