def connected.requests

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

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

257def connected.requests(
258  client: File,
259  generation: U32,
260  mutation: Bool,
261  requests: Protocol.Request & Protocol.Request
262) -> IO(Result<&1, &1, Error, Protocol.Response>):
263  match requests:
264    case (wire_request, retained_request):
265      do IO<Result<&1, &1, Error, Protocol.Response>>:
266        write_result : File & Result<&1, &1, U32 & String, Unit> <-
267          Io.write_all(client, Protocol.encode(wire_request))
268        written(write_result, retained_request, generation, mutation)