Module Async_kernel.Tail
A pointer to the end of an Async_stream
that can be used to extend the stream.
module Deferred = Async_kernel__.Deferred1
type 'a t
= 'a Async_kernel__.Types.Tail.t
val sexp_of_t : ('a -> Ppx_sexp_conv_lib.Sexp.t) -> 'a t -> Ppx_sexp_conv_lib.Sexp.t
val create : unit -> _ t
create ()
returns a new tail.
val extend : 'a t -> 'a -> unit
extend t v
extends the stream, and will raise an exception ift
has been closed.
val close_exn : _ t -> unit
close_exn t
closest
. Subsequent calls toclose_exn
orextend
will raise an exception.
val close_if_open : _ t -> unit
close_if_open t
closest
, if it's not already closed. Ift
is already closed, then this is a no-op.
val is_closed : _ t -> bool
is_closed t
returns true iff the streamt
is closed.
module Stream : sig ... end