def stream.result

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

import Base
import mylsm-lsm-store@0.6.0.1/src/hub_sha/state.bend as S
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

309def stream.result(
310  +compressed: S.State,
311  joined: Packed.Bytes,
312  tail_length: Nat & Nat,
313  total: Nat
314) -> Result<&1, &1, StreamError, Stream>:
315  match tail_length:
316    case (full_length, remainder):
317      stream.result.lengths(compressed, joined,
318        QueuePolicy.nat.clone.pair(full_length), remainder, total)