#
val timeout : Core.Std.Time.Span.t -> unit Async_extended.Std.Cml.event
#
module Branch : sig
#
val (==>) : 'a Async_extended.Std.Cml.event
-> ('a
-> 'b Async_extended.Std.Cml.t)
-> 'b
t
#
val select : 'a
t list
-> 'a Async_extended.Std.Cml.t
end
#
val (|>>|) : (cin:'a -> cout:'b Async_extended.Std.Cml.cout -> unit) -> (cin:'b Async_extended.Std.Cml.cin -> cout:'c -> unit) -> cin:'a -> cout:'c -> unit
#
val (>>|) : (cout:'b Async_extended.Std.Cml.cout -> unit) -> (cin:'b Async_extended.Std.Cml.cin -> cout:'c -> unit) -> cin:unit -> cout:'c -> unit
#
val (|>>) : (cin:'a -> cout:'b Async_extended.Std.Cml.cout -> unit) -> (cin:'b Async_extended.Std.Cml.cin -> unit) -> cin:'a -> cout:unit -> unit
#
val echo : accum:('a -> 'a -> 'a) -> delay:('a -> Core.Std.Time.Span.t) -> cin:'a Async_extended.Std.Cml.cin -> cout:'a Async_extended.Std.Cml.cout -> unit