package async_kernel

  1. Overview
  2. Docs
Monadic concurrency library

Install 

dune-project
 Dependency

github.com Readme Changelog MIT License Edit opam file Versions (6)

Authors

  1. J
    Jane Street Group, LLC

Maintainers

  1. J
    Jane Street developers

Sources

v0.17.0.tar.gz
sha256=01ced973dbc70535f692f38bed524ae82dba17e26e58791b2fbf0d647b160d2e

doc/async_kernel/Async_kernel/Tail/index.html

Module Async_kernel.TailSource

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.