Module Low_latency_transport = Async_extra.Rpc_transport_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 Handler_result = Async_rpc_kernel.Transport_intf.Handler_result

module Reader : sig .. end

module Send_result = Async_rpc_kernel.Transport_intf.Send_result

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 -> Async_extra.Import.Fd.t -> t