def session.call

mylsm-lsm-store@0.6.0.1 · src/coordinator/Client.bend:424

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/ClientPolicy.bend as Policy
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

424# Sends one operation with the next unique ID and retains the updated session.
425def session.call(
426  session: Session,
427  operation: U32,
428  payload: Bytes.Bytes
429) -> IO(Session & Result<&1, &1, Error, Protocol.Response>):
430  match session:
431    case Session{endpoint, generation, requests}:
432      session.call.decision(endpoint, generation, operation, payload,
433        Policy.request_id.take(requests))