Up

Module Writer

Signature

val sexp_of_t : t -> Sexplib.Sexp.t
val close : t -> unit Async_kernel.Std.Deferred.t
val is_closed : t -> bool
val monitor : t -> Async_kernel.Std.Monitor.t
val bytes_to_write : t -> int
val stopped : t -> unit Async_kernel.Std.Deferred.t
val flushed : t -> unit Async_kernel.Std.Deferred.t
val ready_to_write : t -> unit Async_kernel.Std.Deferred.t
val send_bin_prot_and_bigstring : t -> 'a Core_kernel.Std.Bin_prot.Type_class.writer -> 'a -> buf:Core_kernel.Std.Bigstring.t -> pos:int -> len:int -> unit Async_rpc_kernel.Transport_intf.Send_result.t
val send_bin_prot_and_bigstring_non_copying : t -> 'a Core_kernel.Std.Bin_prot.Type_class.writer -> 'a -> buf:Core_kernel.Std.Bigstring.t -> pos:int -> len:int -> unit Async_kernel.Std.Deferred.t Async_rpc_kernel.Transport_intf.Send_result.t
val pack : (module S with type t = 'a) -> 'a -> t
val can_send : t -> bool
val transfer : t -> ?max_num_values_per_read:int -> 'a Async_kernel.Std.Pipe.Reader.t -> ('a -> unit) -> unit Async_kernel.Std.Deferred.t