Eager_deferred.QueueSourceSimilar to Deferred.Queue but eager when passing ~how:`Sequential. The functions in Queue raise if the queue is mutated during execution.
val foldi :
'a Core.Queue.t ->
init:'b ->
f:(int -> 'b -> 'a -> 'b Async_kernel.Deferred.t) ->
'b Async_kernel.Deferred.tval fold :
'a Core.Queue.t ->
init:'b ->
f:('b -> 'a -> 'b Async_kernel.Deferred.t) ->
'b Async_kernel.Deferred.tval find :
'a Core.Queue.t ->
f:('a -> bool Async_kernel.Deferred.t) ->
'a option Async_kernel.Deferred.tval findi :
'a Core.Queue.t ->
f:(int -> 'a -> bool Async_kernel.Deferred.t) ->
(int * 'a) option Async_kernel.Deferred.tval find_map :
'a Core.Queue.t ->
f:('a -> 'b option Async_kernel.Deferred.t) ->
'b option Async_kernel.Deferred.tval find_mapi :
'a Core.Queue.t ->
f:(int -> 'a -> 'b option Async_kernel.Deferred.t) ->
'b option Async_kernel.Deferred.tval exists :
'a Core.Queue.t ->
f:('a -> bool Async_kernel.Deferred.t) ->
bool Async_kernel.Deferred.tval existsi :
'a Core.Queue.t ->
f:(int -> 'a -> bool Async_kernel.Deferred.t) ->
bool Async_kernel.Deferred.tval for_all :
'a Core.Queue.t ->
f:('a -> bool Async_kernel.Deferred.t) ->
bool Async_kernel.Deferred.tval for_alli :
'a Core.Queue.t ->
f:(int -> 'a -> bool Async_kernel.Deferred.t) ->
bool Async_kernel.Deferred.tval init :
how:Async_kernel.Monad_sequence.how ->
int ->
f:(int -> 'a Async_kernel.Deferred.t) ->
'a Core.Queue.t Async_kernel.Deferred.tval iter :
how:Async_kernel.Monad_sequence.how ->
'a Core.Queue.t ->
f:('a -> unit Async_kernel.Deferred.t) ->
unit Async_kernel.Deferred.tval iteri :
how:Async_kernel.Monad_sequence.how ->
'a Core.Queue.t ->
f:(int -> 'a -> unit Async_kernel.Deferred.t) ->
unit Async_kernel.Deferred.tval map :
how:Async_kernel.Monad_sequence.how ->
'a Core.Queue.t ->
f:('a -> 'b Async_kernel.Deferred.t) ->
'b Core.Queue.t Async_kernel.Deferred.tval mapi :
how:Async_kernel.Monad_sequence.how ->
'a Core.Queue.t ->
f:(int -> 'a -> 'b Async_kernel.Deferred.t) ->
'b Core.Queue.t Async_kernel.Deferred.tval filter :
how:Async_kernel.Monad_sequence.how ->
'a Core.Queue.t ->
f:('a -> bool Async_kernel.Deferred.t) ->
'a Core.Queue.t Async_kernel.Deferred.tval filteri :
how:Async_kernel.Monad_sequence.how ->
'a Core.Queue.t ->
f:(int -> 'a -> bool Async_kernel.Deferred.t) ->
'a Core.Queue.t Async_kernel.Deferred.tval filter_map :
how:Async_kernel.Monad_sequence.how ->
'a Core.Queue.t ->
f:('a -> 'b option Async_kernel.Deferred.t) ->
'b Core.Queue.t Async_kernel.Deferred.tval filter_mapi :
how:Async_kernel.Monad_sequence.how ->
'a Core.Queue.t ->
f:(int -> 'a -> 'b option Async_kernel.Deferred.t) ->
'b Core.Queue.t Async_kernel.Deferred.tval concat_map :
how:Async_kernel.Monad_sequence.how ->
'a Core.Queue.t ->
f:('a -> 'b Core.Queue.t Async_kernel.Deferred.t) ->
'b Core.Queue.t Async_kernel.Deferred.tval concat_mapi :
how:Async_kernel.Monad_sequence.how ->
'a Core.Queue.t ->
f:(int -> 'a -> 'b Core.Queue.t Async_kernel.Deferred.t) ->
'b Core.Queue.t Async_kernel.Deferred.t