package async
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/Transport/Reader/index.html
Module Transport.Reader
include module type of struct include Async_rpc_kernel.Rpc.Transport.Reader end
module type S = Async_rpc_kernel.Rpc.Transport.Reader.S
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 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 of_reader : max_message_size:int -> Async_reader.t -> t
sectionYPositions = computeSectionYPositions($el), 10)"
x-init="setTimeout(() => sectionYPositions = computeSectionYPositions($el), 10)"
>