package async_kernel
Module Deferred.SetSource
type ('a, 'cmp) t := ('a, 'cmp) Core.Set.tSource
val count :
how:Monad_sequence.how ->
('a, _) t ->
f:('a -> bool Deferred.t) ->
int Deferred.thow is exposed here so if f has a lot of work that can be done asynchronously, it can first be concurrently applied to elements of t and only then counted.
Source
val sum :
(module Base.Container.Summable with type t = 'sum) ->
how:Monad_sequence.how ->
('a, _) t ->
f:('a -> 'sum Deferred.t) ->
'sum Deferred.thow is exposed here so if f has a lot of work that can be done asynchronously, it can first be concurrently applied to elements of t and only then summed.
Source
val map :
('b, 'cmp) Base.Comparator.Module.t ->
how:Monad_sequence.how ->
('a, _) t ->
f:('a -> 'b Deferred.t) ->
('b, 'cmp) t Deferred.tSource
val filter_map :
('b, 'cmp) Base.Comparator.Module.t ->
how:Monad_sequence.how ->
('a, _) t ->
f:('a -> 'b option Deferred.t) ->
('b, 'cmp) t Deferred.tSource
val filter :
how:Monad_sequence.how ->
('a, 'cmp) t ->
f:('a -> bool Deferred.t) ->
('a, 'cmp) t Deferred.tSource
val fold :
('a, _) t ->
init:'accum ->
f:('accum -> 'a -> 'accum Deferred.t) ->
'accum Deferred.tSource
val fold_right :
('a, _) t ->
init:'accum ->
f:('a -> 'accum -> 'accum Deferred.t) ->
'accum Deferred.tSource
val iter :
how:Monad_sequence.how ->
('a, _) t ->
f:('a -> unit Deferred.t) ->
unit Deferred.t