Up

Module Rpc_transport_low_latency

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

Signature

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
module Header : sig .. end
module Reader : sig .. end
module Writer : sig .. end
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.Std.Deferred.t
val create : ?config:Config.t -> max_message_size:int -> Import.Fd.t -> t