To focus the search input from anywhere on the page, press the 'S' key.
in-package search v0.1.0
package async_rpc_kernel
-
async_rpc_kernel
-
Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
val sexp_of_t : t -> Sexplib0.Sexp.tval close : t -> unit Async_kernel.Deferred.tval is_closed : t -> boolval read_forever :
t ->
on_message:
(Core.Bigstring.t ->
pos:int ->
len:int ->
'a Async_rpc_kernel__.Transport_intf.Handler_result.t) ->
on_end_of_batch:(unit -> unit) ->
('a, [ `Eof | `Closed ]) Core.Result.t Async_kernel.Deferred.tStart 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.