package async_kernel

You can search for identifiers within the package.

in-package search v0.2.0

Monadic concurrency library

Install

sha256=01ced973dbc70535f692f38bed524ae82dba17e26e58791b2fbf0d647b160d2e

A pointer to the end of an Async_stream that can be used to extend the stream.

Sourcemodule Deferred : sig ... end

Sourcetype 'a t

Sourceval sexp_of_t : ('a -> Sexplib0.Sexp.t) -> 'a t -> Sexplib0.Sexp.t

Sourceval create : unit -> _ t

create () returns a new tail.

Sourceval extend : 'a t -> 'a -> unit

extend t v extends the stream, and will raise an exception if t has been closed.

Sourceval close_exn : _ t -> unit

close_exn t closes t. Subsequent calls to close_exn or extend will raise an exception.

Sourceval close_if_open : _ t -> unit

close_if_open t closes t, if it's not already closed. If t is already closed, then this is a no-op.

Sourceval is_closed : _ t -> bool

is_closed t returns true iff the stream t is closed.

Sourcemodule Stream : sig ... end

Sourceval collect : 'a t -> 'a Stream.t

collect t returns the stream starting at the current position of the tail, i.e. the stream consisting of all subsequent extends.