Module Piaf_streamSource

Sourcetype _ t
Sourceval empty : unit -> _ t
Sourceval from : f:(unit -> 'a option) -> 'a t
Sourceval create : int -> 'a t * ('a option -> unit)
Sourceval close : _ t -> unit
Sourceval closed : _ t -> unit Eio.Promise.t
Sourceval when_closed : f:(unit -> unit) -> _ t -> unit
Sourceval is_closed : _ t -> bool
Sourceval take : 'a t -> 'a option
Sourceval of_list : 'a list -> 'a t
Sourceval to_list : 'a t -> 'a list
Sourceval map : f:('a -> 'b) -> 'a t -> 'b t
Sourceval iter : f:('a -> unit) -> 'a t -> unit
Sourceval iter_p : sw:Eio.Switch.t -> f:('a -> unit) -> 'a t -> unit
Sourceval fold : f:('acc -> 'a -> 'acc) -> init:'acc -> 'a t -> 'acc
Sourceval drain : _ t -> unit
Sourceval drain_available : _ t -> unit