def open

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

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

31# Decodes a successful owner cursor-open response or preserves its rejection.
32def open(status: Protocol.ResponseStatus, payload: Bytes.Bytes) -> OpenDecision:
33  match status:
34    case Protocol.Success{}:
35      open.parsed(Protocol.snapshot.id.read(payload))
36    case _: OpenRejected{status}