Module `Async_rpc__.Rpc_transport`

module Async_reader = Async_rpc__.Import.Reader

module Async_writer = Async_rpc__.Import.Writer

module Reader : sig ... end

module Writer : sig ... end

include module type of sig ... end with module Reader := Async_rpc__.Import.Rpc_kernel.Transport.Reader with module Writer := Async_rpc__.Import.Rpc_kernel.Transport.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 -> Ppx_sexp_conv_lib.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 -> Async_rpc__.Import.Fd.t -> t