Up

Module Reader

Signature

module type S = Transport_intf.Reader
include S
type 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 Transport_intf.Handler_result.t) -> on_end_of_batch:(unit -> unit) -> ('a, [
| `Eof
| `Closed
]) Core_kernel.Std.Result.t Async_kernel.Std.Deferred.t

Start reading incoming messages and pass them to on_message, until it returns Stop _.

on_end_of_batch is called after processing a batch of messages, before waiting for the file descriptor to become readable again.

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

Convenience function to wait for the first message and un-bin_prot it.

Async RPC uses this to handle the handshake at the beginning of the message stream.