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