Low_latency_transport (async.Async_rpc.Rpc.Low_latency

module Config : sig ... end

module Reader : sig ... end

module Writer : sig ... end

include module type of struct include Async_rpc_kernel.Rpc.Transport end with module Reader := Async_rpc_kernel.Rpc.Transport.Reader with module Writer := Async_rpc_kernel.Rpc.Transport.Writer

module Header : sig ... end

Binary headers containing message lengths. All transports should use this to ensure binary compatibility.

module Handler_result : sig ... end

module Send_result : sig ... end

type t = {

reader : Async_rpc_kernel.Rpc.Transport.Reader.t;

writer : Async_rpc_kernel.Rpc.Transport.Writer.t;

}

val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.t

val close : t -> unit Async_kernel.Deferred.t

Closes both parts of the transport.

val create : ?⁠config:Config.t -> max_message_size:int -> Async_unix.Fd.t -> t