Rpc_transport (async_extra.Async_extra.Rpc

module Async_reader = Import.Reader

The Reader and Writer modules from Async, renamed to avoid conflicting with Reader and Writer below.

module Async_writer = Import.Writer

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

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 of_reader_writer : max_message_size:int ‑> Async_reader.t ‑> Async_writer.t ‑> t

val of_fd : ?buffer_age_limit:Async_writer.buffer_age_limit ‑> ?reader_buffer_size:int ‑> max_message_size:int ‑> Import.Fd.t ‑> t