def snapshot.cursor.next.decision

mylsm-lsm-store@0.6.0.1 · src/coordinator/ByteClient.bend:403

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/Client.bend as Client
import mylsm-lsm-store@0.6.0.1/src/coordinator/CursorCodec.bend as CursorCodec
import mylsm-lsm-store@0.6.0.1/src/coordinator/OwnerCursorCodec.bend as OwnerCursorCodec

403# Maps one pure next-response decision into a client result.
404def snapshot.cursor.next.decision(
405  decision: OwnerCursorCodec.NextDecision
406) -> Result<&1, &1, Client.Error, CursorCodec.Frame>:
407  match decision:
408    case OwnerCursorCodec.NextFrame{frame}: Done{frame}
409    case OwnerCursorCodec.NextRejected{status}:
410      Fail{Client.OwnerRejected{status}}
411    case OwnerCursorCodec.NextMalformed{}:
412      Fail{Client.MalformedResponse{}}