~/jendhub

def stream.update.state

mylsm-lsm-store@0.6.0.1 · src/hub_sha/sha256.bend:370

import mylsm-lsm-store@0.6.0.1/src/hub_sha/sha256.bend as Sha256
import Base
import bend-kit-bytes@0.3.2.0/bytes.bend as Packed
import mylsm-lsm-store@0.6.0.1/src/coordinator/QueuePolicy.bend as QueuePolicy

370def stream.update.state(
371  state: Stream,
372  input: Packed.Bytes & U32
373) -> Result<&1, &1, StreamError, Stream>:
374  match state:
375    case Stream{compressed, tail, +total}:
376      match input:
377        case (incoming, input_length):
378          stream.update.state.lengths(compressed, tail, incoming,
379            QueuePolicy.nat.clone.pair(U32.to_nat(input_length)),
380            QueuePolicy.nat.clone.pair(total))

Uses (10)

Used by (1)