package async

  1. Overview
  2. Docs
Monadic concurrency library

Install

Dune Dependency

Authors

Maintainers

Sources

async-v0.13.0.tar.gz
sha256=fef9ebe342ea59d7804f6292b7891ad664a8ba8d4174a1b202db91363a9c71ab
md5=fbfc7059179bc9ddd5dc1411e7d2e815

doc/async.async_rpc/Async_rpc/Rpc/Low_latency_transport/Reader/index.html

Module Low_latency_transport.Reader

include module type of struct include Async_rpc_kernel.Rpc.Transport.Reader end
include S
val sexp_of_t : t -> Ppx_sexp_conv_lib.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 Async_rpc_kernel__.Transport_intf.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.

val pack : (module S with type t = 'a) -> 'a -> t
val read_one_message_bin_prot : t -> 'a Core_kernel.Bin_prot.Type_class.reader -> ('a, [ `Closed | `Eof ]) Core_kernel.Result.t Async_kernel.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.

val create : ?config:Config.t -> max_message_size:int -> Async_unix.Fd.t -> t
OCaml

Innovation. Community. Security.