Module Fiber_stream.InSource

Sourcetype 'a t
Sourceval create : (unit -> 'a option Fiber.t) -> 'a t
Sourceval empty : unit -> 'a t
Sourceval of_list : 'a list -> 'a t
Sourceval read : 'a t -> 'a option Fiber.t
Sourceval map : 'a t -> f:('a -> 'b) -> 'b t
Sourceval filter : 'a t -> f:('a -> bool) -> 'a t
Sourceval filter_map : 'a t -> f:('a -> 'b option) -> 'b t
Sourceval sequential_iter : 'a t -> f:('a -> unit Fiber.t) -> unit Fiber.t