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
module Header = Async_rpc_kernel__Transport.Header
module Handler_result = Async_rpc_kernel.Transport_intf.Handler_result
module Reader = Async_rpc_kernel__Transport.Reader
module Send_result = Async_rpc_kernel.Transport_intf.Send_result
module Writer = Async_rpc_kernel__Transport.Writer
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