def tx.flight.complete

mylsm-lsm-store@0.6.0.1 · src/coordinator/TransportBudgetPolicy.bend:92

import Base
import mylsm-lsm-store@0.6.0.1/src/coordinator/Protocol.bend as Protocol

92def tx.flight.complete(
93  flight: InFlight,
94  response: Protocol.Response
95) -> DispatchCompletion:
96  match flight:
97    case DispatchedRequest{reservation}:
98      DispatchCompleted{reservation, response}
99    case flight: DispatchCompletionRejected{flight, response}