Module `Deferred.Queue`Source

Similar to Deferred.Queue but eager when passing ~how:`Sequential. The functions in Queue raise if the queue is mutated during execution.

Sourceval foldi : 'a Core.Queue.t -> init:'b -> f:(int -> 'b -> 'a -> 'b t) -> 'b t

Sourceval fold : 'a Core.Queue.t -> init:'b -> f:('b -> 'a -> 'b t) -> 'b t

Sourceval find : 'a Core.Queue.t -> f:('a -> bool t) -> 'a option t

Sourceval findi : 'a Core.Queue.t -> f:(int -> 'a -> bool t) -> (int * 'a) option t

Sourceval find_map : 'a Core.Queue.t -> f:('a -> 'b option t) -> 'b option t

Sourceval find_mapi : 'a Core.Queue.t -> f:(int -> 'a -> 'b option t) -> 'b option t

Sourceval exists : 'a Core.Queue.t -> f:('a -> bool t) -> bool t

Sourceval existsi : 'a Core.Queue.t -> f:(int -> 'a -> bool t) -> bool t

Sourceval for_all : 'a Core.Queue.t -> f:('a -> bool t) -> bool t

Sourceval for_alli : 'a Core.Queue.t -> f:(int -> 'a -> bool t) -> bool t

Sourceval all : 'a t Core.Queue.t -> 'a Core.Queue.t t

Sourceval all_unit : unit t Core.Queue.t -> unit t

val init : 
  how:Async_kernel.Monad_sequence.how ->
  int ->
  f:(int -> 'a t) ->
  'a Core.Queue.t t

val iter : 
  how:Async_kernel.Monad_sequence.how ->
  'a Core.Queue.t ->
  f:('a -> unit t) ->
  unit t

val iteri : 
  how:Async_kernel.Monad_sequence.how ->
  'a Core.Queue.t ->
  f:(int -> 'a -> unit t) ->
  unit t

val map : 
  how:Async_kernel.Monad_sequence.how ->
  'a Core.Queue.t ->
  f:('a -> 'b t) ->
  'b Core.Queue.t t

val mapi : 
  how:Async_kernel.Monad_sequence.how ->
  'a Core.Queue.t ->
  f:(int -> 'a -> 'b t) ->
  'b Core.Queue.t t

val filter : 
  how:Async_kernel.Monad_sequence.how ->
  'a Core.Queue.t ->
  f:('a -> bool t) ->
  'a Core.Queue.t t

val filteri : 
  how:Async_kernel.Monad_sequence.how ->
  'a Core.Queue.t ->
  f:(int -> 'a -> bool t) ->
  'a Core.Queue.t t

val filter_map : 
  how:Async_kernel.Monad_sequence.how ->
  'a Core.Queue.t ->
  f:('a -> 'b option t) ->
  'b Core.Queue.t t

val filter_mapi : 
  how:Async_kernel.Monad_sequence.how ->
  'a Core.Queue.t ->
  f:(int -> 'a -> 'b option t) ->
  'b Core.Queue.t t

val concat_map : 
  how:Async_kernel.Monad_sequence.how ->
  'a Core.Queue.t ->
  f:('a -> 'b Core.Queue.t t) ->
  'b Core.Queue.t t

val concat_mapi : 
  how:Async_kernel.Monad_sequence.how ->
  'a Core.Queue.t ->
  f:(int -> 'a -> 'b Core.Queue.t t) ->
  'b Core.Queue.t t

Install