module Async_reader = Async_unix.ReaderThe Reader and Writer modules from Async, renamed to avoid conflicting with Reader and Writer below.
module Async_writer = Async_unix.Writermodule Reader : sig ... endmodule Writer : sig ... endinclude module type of struct include Async_rpc_kernel.Rpc.Transport end
with module Reader := Async_rpc_kernel.Rpc.Transport.Reader
with module Writer := Async_rpc_kernel.Rpc.Transport.Writermodule Header = Async_rpc_kernel.Rpc.Transport.HeaderBinary headers containing message lengths. All transports should use this to ensure binary compatibility.
module Handler_result = Async_rpc_kernel.Rpc.Transport.Handler_resultmodule Send_result = Async_rpc_kernel.Rpc.Transport.Send_resulttype t = {reader : Async_rpc_kernel.Rpc.Transport.Reader.t;writer : Async_rpc_kernel.Rpc.Transport.Writer.t;}val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.tval close : t -> unit Async_kernel.Deferred.tCloses both parts of the transport.
val of_reader_writer :
max_message_size:int ->
Async_reader.t ->
Async_writer.t ->
tval of_fd :
?buffer_age_limit:Async_writer.buffer_age_limit ->
?reader_buffer_size:int ->
max_message_size:int ->
Async_unix.Fd.t ->
t