include sig ... end
val sexp_of_t : t ‑> Sexplib.Sexp.t
val close : t ‑> unit Async_kernel.Deferred.t
val is_closed : t ‑> bool
val read_forever : t ‑> on_message:(Core_kernel.Bigstring.t ‑> pos:int ‑> len:int ‑> 'a Handler_result.t) ‑> on_end_of_batch:(unit ‑> unit) ‑> ('a, [ `Eof | `Closed ]) Core_kernel.Result.t Async_kernel.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.