module Tail: Raw_tail
module Deferred: Raw_deferred
module Ivar: Raw_ivar
module Stream: Raw_stream
type ('a, 'execution_context)
t = {
|
mutable next : |
val sexp_of_t : 'a -> 'b -> ('c, 'd) t -> Core.Std.Sexp.t
val create : unit -> ('a, 'b) t
val collect : ('a, 'b) t ->
(('a, 'b) Stream.next, 'b) Deferred.t