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.

Signature

include Deferred1.Monad_sequence with type 'a t = 'a Core_kernel.Std.Queue.t

type 'a monad

type 'a t = 'a Core_kernel.Std.Queue.t

val foldi : 'a t -> init:'b -> f:(int -> 'b -> 'a -> 'b monad) -> 'b monad

val fold : 'a t -> init:'b -> f:('b -> 'a -> 'b monad) -> 'b monad

val init : ?how:Monad_sequence.how -> int -> f:(int -> 'a monad) -> 'a t monad

default how is `Sequential

val iter : ?how:Monad_sequence.how -> 'a t -> f:('a -> unit monad) -> unit monad

val iteri : ?how:Monad_sequence.how -> 'a t -> f:(int -> 'a -> unit monad) -> unit monad

val map : ?how:Monad_sequence.how -> 'a t -> f:('a -> 'b monad) -> 'b t monad

val filter : ?how:Monad_sequence.how -> 'a t -> f:('a -> bool monad) -> 'a t monad

val filter_map : ?how:Monad_sequence.how -> 'a t -> f:('a -> 'b option monad) -> 'b t monad

val concat_map : ?how:Monad_sequence.how -> 'a t -> f:('a -> 'b t monad) -> 'b t monad

val find : 'a t -> f:('a -> bool monad) -> 'a option monad

val find_map : 'a t -> f:('a -> 'b option monad) -> 'b option monad

val all : 'a monad t -> 'a t monad

val all_unit : unit monad t -> unit monad