def call.admitted

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

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

304def call.admitted(
305  endpoint: String,
306  request: Protocol.Request,
307  generation: U32,
308  mutation: Bool,
309  admitted: Bool
310) -> IO(Result<&1, &1, Error, Protocol.Response>):
311  match admitted:
312    case False{}:
313      IO.pure(Result<&1, &1, Error, Protocol.Response>,
314        result.failure(FrameTooLarge{}))
315    case True{}:
316      do IO<Result<&1, &1, Error, Protocol.Response>>:
317        client : Result<&1, &1, UnixSocket.Error, File> <-
318          UnixSocket.create()
319        created(client, endpoint, request, generation, mutation)