def next

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

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

44# Decodes a raw-byte cursor frame only from a successful owner response.
45def next(status: Protocol.ResponseStatus, payload: Bytes.Bytes) -> NextDecision:
46  match status:
47    case Protocol.Success{}:
48      next.decoded(CursorCodec.decode(payload))
49    case _: NextRejected{status}