def header.decision

mylsm-lsm-store@0.6.0.1 · src/coordinator/Io.bend:560

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

560def header.decision(
561  file: File,
562  bytes: Bytes.Bytes,
563  decision: Protocol.FrameDecision,
564  max_payload: Nat
565) -> IO(File & Result<&1, &1, Error, Protocol.Request>):
566  match decision:
567    case Protocol.NeedMore{}:
568      header.length.result(file, Bytes.get.u32be(bytes, 20), max_payload)
569    case _:
570      IO.pure(File & Result<&1, &1, Error, Protocol.Request>,
571        frame.result(file, decision))