Module Async_extra.Rpc_transport_low_latency

This module implements a RPC transport optimized for low-latency.

module Config : sig ... end

All the following create functions take a max_message_size argument in addition to a Config.t. The final max_message_size will be the min of both.

The rationale for this is that max_message_size is more a property of the protocol and should be specified by the programmer, while other configuration parameters are for tuning purposes.

module Reader : sig ... end
module Writer : sig ... end
include module type of sig ... end with module Reader := Reader with module Writer := Writer
type t = Async_rpc_kernel__Transport.t = {
reader : Reader.t;
writer : Writer.t;
}
val sexp_of_t : t ‑> Sexplib.Sexp.t
val close : t ‑> unit Async_kernel.Deferred.t
val create : ?config:Config.t ‑> max_message_size:int ‑> Import.Fd.t ‑> t