async_js

A small library that provide Async support for JavaScript platforms
package async_js
Legend:
Library
Module
Module type
Parameter
Class
Class type
Library async_js
Module type Async_js . Rpc . Transport . Reader . S
type t
val sexp_of_t : t -> Sexplib0.Sexp.t
val close : t -> unit Async_kernel.Deferred.t
val is_closed : t -> bool
val 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.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.