module Raw_async_stream:sig
..end
type('a, 'execution_context)
next_ =('a, 'execution_context) Raw_stream.next
=
| |
Nil |
| |
Cons of |
type'a
next =('a, Execution_context.t) next_
type'a
t =('a, Execution_context.t) Raw_stream.t
val sexp_of_t : ('a -> Core.Std.Sexp.t) -> 'a t -> Core.Std.Sexp.t
val next : 'a -> 'a