def created

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

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

286# Connects a new socket and classifies failures before dispatch.
287def created(
288  result: Result<&1, &1, UnixSocket.Error, File>,
289  endpoint: String,
290  request: Protocol.Request,
291  generation: U32,
292  mutation: Bool
293) -> IO(Result<&1, &1, Error, Protocol.Response>):
294  match result:
295    case Done{client}:
296      do IO<Result<&1, &1, Error, Protocol.Response>>:
297        connection : File & Result<&1, &1, UnixSocket.Error, Unit> <-
298          UnixSocket.connect(client, endpoint)
299        connected(connection, request, generation, mutation)
300    case Fail{error}:
301      IO.pure(Result<&1, &1, Error, Protocol.Response>,
302        result.failure(ConnectFailure{error}))