def stream.block.records

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

import Base
import mylsm-lsm-store@0.6.0.1/src/MemTable.bend as MemTable
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

1435def stream.block.records(
1436  +level: U32,
1437  +total: U32,
1438  +block_count: U32,
1439  +remaining: U32,
1440  +entries_left: U32,
1441  entries: List<&2, MemTable.Entry>,
1442  hashes: List<&1, Bytes.Bytes>,
1443  records: ParsedEntries,
1444  +count: U32,
1445  digest: Bytes.Bytes
1446) -> Result<&1, &1, Error, StreamState>:
1447  match records:
1448    case Entries{reversed, previous}:
1449      Done{StreamState{level, total, block_count,
1450        (remaining - 1 : U32), (entries_left - count : U32),
1451        previous, List.append(&2, MemTable.Entry, reversed, entries),
1452        digest <> hashes}}