def connected

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

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

270# Writes one request after the owner endpoint accepts the connection.
271def connected(
272  pair: File & Result<&1, &1, UnixSocket.Error, Unit>,
273  request: Protocol.Request,
274  generation: U32,
275  mutation: Bool
276) -> IO(Result<&1, &1, Error, Protocol.Response>):
277  match pair:
278    case (client, Done{Unit{}}):
279      connected.requests(client, generation, mutation,
280        request.clone.pair(request))
281    case (client, Fail{error}):
282      do IO<Result<&1, &1, Error, Protocol.Response>>:
283        _closed : Unit <- File.close(client)
284        return result.failure(ConnectFailure{error})