def close

mylsm-lsm-store@0.6.0.1 · src/coordinator/OwnerCursorCodec.bend:57

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

57# Accepts cursor close only when success carries no trailing payload.
58def close(status: Protocol.ResponseStatus, payload: Bytes.Bytes) -> CloseDecision:
59  match status:
60    case Protocol.Success{}:
61      close.measured(Bytes.length(payload))
62    case _: CloseRejected{status}