def written

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

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

241# Sends a frame result into response reading or mutation uncertainty.
242def written(
243  pair: File & Result<&1, &1, U32 & String, Unit>,
244  request: Protocol.Request,
245  generation: U32,
246  mutation: Bool
247) -> IO(Result<&1, &1, Error, Protocol.Response>):
248  match pair:
249    case (client, Done{Unit{}}):
250      response.request(client, request, generation, mutation)
251    case (client, Fail{(code, message)}):
252      do IO<Result<&1, &1, Error, Protocol.Response>>:
253        _closed : Unit <- File.close(client)
254        return result.failure(disconnect.error(mutation,
255          Io.host.error(code, message)))