Module Deferred.Queue

All Deferred_queue iteration functions first copy the queue (to a list) and then start calling the user function f. So, if f modifies the queue, that will have no effect on the iteration.

val foldi : 'a Core_kernel.Queue.t -> init:'b -> f:(int -> 'b -> 'a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val fold : 'a Core_kernel.Queue.t -> init:'b -> f:('b -> 'a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val find : 'a Core_kernel.Queue.t -> f:('a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val findi : 'a Core_kernel.Queue.t -> f:(int -> 'a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val find_map : 'a Core_kernel.Queue.t -> f:('a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val find_mapi : 'a Core_kernel.Queue.t -> f:(int -> 'a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val exists : 'a Core_kernel.Queue.t -> f:('a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val existsi : 'a Core_kernel.Queue.t -> f:(int -> 'a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val for_all : 'a Core_kernel.Queue.t -> f:('a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val for_alli : 'a Core_kernel.Queue.t -> f:(int -> 'a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val all : 'a Core_kernel.Queue.t -> 'a Async_kernel__Types.Deferred.t
val all_unit : 'a Core_kernel.Queue.t -> 'a Async_kernel__Types.Deferred.t

Deferred iterators

val init : ?⁠how:Monad_sequence.how -> int -> f:(int -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val iter : ?⁠how:Monad_sequence.how -> 'a Core_kernel.Queue.t -> f:('a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val iteri : ?⁠how:Monad_sequence.how -> 'a Core_kernel.Queue.t -> f:(int -> 'a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val map : ?⁠how:Monad_sequence.how -> 'a Core_kernel.Queue.t -> f:('a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val mapi : ?⁠how:Monad_sequence.how -> 'a Core_kernel.Queue.t -> f:(int -> 'a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val filter : ?⁠how:Monad_sequence.how -> 'a Core_kernel.Queue.t -> f:('a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val filteri : ?⁠how:Monad_sequence.how -> 'a Core_kernel.Queue.t -> f:(int -> 'a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val filter_map : ?⁠how:Monad_sequence.how -> 'a Core_kernel.Queue.t -> f:('a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val filter_mapi : ?⁠how:Monad_sequence.how -> 'a Core_kernel.Queue.t -> f:(int -> 'a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val concat_map : ?⁠how:Monad_sequence.how -> 'a Core_kernel.Queue.t -> f:('a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t
val concat_mapi : ?⁠how:Monad_sequence.how -> 'a Core_kernel.Queue.t -> f:(int -> 'a -> 'a Async_kernel__Types.Deferred.t) -> 'a Async_kernel__Types.Deferred.t