Up
Module
Reader
Signature
module type
S
=
Async_rpc_kernel.Transport_intf.Reader
type
t =
Async_rpc_kernel.Transport.Reader.t
val
sexp_of_t :
t
->
Sexplib.Sexp.t
val
close :
t
-> unit
Async_kernel.Std.Deferred.t
val
is_closed :
t
-> bool
val
read_forever :
t
-> on_message:(
Core_kernel.Std.Bigstring.t
-> pos:int -> len:int -> 'a
Async_rpc_kernel.Transport_intf.Handler_result.t
) -> on_end_of_batch:(unit -> unit) -> ('a, [
| `Closed
| `Eof
])
Core_kernel.Std.Result.t
Async_kernel.Std.Deferred.t
val
pack : (
module
S
with
type
t
= 'a) -> 'a ->
t
val
read_one_message_bin_prot :
t
-> 'a
Core_kernel.Std.Bin_prot.Type_class.reader
-> ('a, [
| `Closed
| `Eof
])
Core_kernel.Std.Result.t
Async_kernel.Std.Deferred.t