Module `Tail.Deferred`Source

Sourcemodule Scheduler : sig ... end

Sourcetype +'a t

Sourceval sexp_of_t : ('a -> Sexplib0.Sexp.t) -> 'a Deferred.t -> Sexplib0.Sexp.t

include Core.Invariant.S1 with type 'a t := 'a Deferred.t

Sourceval invariant : ('a -> unit) -> 'a Deferred.t -> unit

Sourceval of_ivar : 'a Async_kernel__.Types.Ivar.t -> 'a Deferred.t

Sourceval create : ('a Async_kernel__.Types.Ivar.t -> unit) -> 'a Deferred.t

Sourceval peek : 'a Deferred.t -> 'a option

Sourceval value_exn : 'a Deferred.t -> 'a

Sourceval is_determined : _ Deferred.t -> bool

Sourceval upon : 'a Deferred.t -> ('a -> unit) -> unit

Sourcemodule Handler : sig ... end

Source

val add_handler : 
  'a Deferred.t ->
  ('a -> unit) ->
  Execution_context.t ->
  'a Handler.t

Sourceval remove_handler : 'a Deferred.t -> 'a Handler.t -> unit

Sourceval never : unit -> 'a Deferred.t

Sourcemodule M : sig ... end

include module type of struct include M end

Source

val (>>=) : 
  'a Async_kernel__.Types.Deferred.t ->
  ('a -> 'b Async_kernel__.Types.Deferred.t) ->
  'b Async_kernel__.Types.Deferred.t

Source

val (>>|) : 
  'a Async_kernel__.Types.Deferred.t ->
  ('a -> 'b) ->
  'b Async_kernel__.Types.Deferred.t

Sourcemodule Monad_infix = M.Monad_infix

Source

val bind : 
  'a Async_kernel__.Types.Deferred.t ->
  f:('a -> 'b Async_kernel__.Types.Deferred.t) ->
  'b Async_kernel__.Types.Deferred.t

Source

val map : 
  'a Async_kernel__.Types.Deferred.t ->
  f:('a -> 'b) ->
  'b Async_kernel__.Types.Deferred.t

Source

val join : 
  'a Async_kernel__.Types.Deferred.t Async_kernel__.Types.Deferred.t ->
  'a Async_kernel__.Types.Deferred.t

Source

val ignore_m : 
  'a Async_kernel__.Types.Deferred.t ->
  unit Async_kernel__.Types.Deferred.t

Sourceval return : 'a -> 'a Deferred.t

Sourcemodule Let_syntax : sig ... end

Sourceval unit : unit Deferred.t

Sourceval both : 'a Deferred.t -> 'b Deferred.t -> ('a * 'b) Deferred.t

Sourcemodule Infix : sig ... end

Sourceval don't_wait_for : unit Deferred.t -> unit

Sourcemodule Choice : sig ... end

Sourcemodule Unregister : sig ... end

Sourceval choice : 'a Deferred.t -> ('a -> 'b) -> 'b Choice.t

Sourceval enabled : 'a Choice.t list -> (unit -> 'a list) Deferred.t

Sourceval choose_result : 'a Unregister.t -> 'a

Sourceval generic_choose : 'a Choice.t list -> 'a Deferred.t

Source

val choose2 : 
  'a Deferred.t ->
  ('a -> 'b) ->
  'c Deferred.t ->
  ('c -> 'b) ->
  'b Deferred.t

Sourceval choose : 'a Choice.t list -> 'a Deferred.t

Sourceval any_f : 'a Deferred.t list -> ('a -> 'b) -> 'b Deferred.t

Sourceval any : 'a Deferred.t list -> 'a Deferred.t

Sourceval any_unit : unit Deferred.t list -> unit Deferred.t

Source

val for_ : 
  int ->
  to_:int ->
  do_:(int -> unit Async_kernel__.Types.Deferred.t) ->
  unit Deferred.t

Source

val repeat_until_finished : 
  'a ->
  ('a -> [< `Finished of 'b | `Repeat of 'a ] Deferred.t) ->
  'b Deferred.t

Sourceval forever : 'a -> ('a -> 'a Async_kernel__.Types.Deferred.t) -> unit

Sourcetype how = Monad_sequence.how

Sourceval sexp_of_how : how -> Sexplib0.Sexp.t

Source

module type Monad_sequence =
  Monad_sequence.S with type 'a monad := 'a Deferred.t

Sourceval fold : 'a list -> init:'b -> f:('b -> 'a -> 'b Deferred.t) -> 'b Deferred.t

Source

val seqmap : 
  'a list ->
  f:('a -> 'b Async_kernel__.Types.Deferred.t) ->
  'b list Async_kernel__.Types.Deferred.t

Source

val all : 
  'a Async_kernel__.Types.Deferred.t list ->
  'a list Async_kernel__.Types.Deferred.t

Sourceval all_unit : unit Deferred.t list -> unit Deferred.t

Source

val ok : 
  'a Async_kernel__.Types.Deferred.t ->
  ('a, 'b) Core._result Async_kernel__.Types.Deferred.t

Sourcemodule For_tests : sig ... end

Install

Dune Dependency

Authors

Maintainers

Sources

doc/async_kernel/Async_kernel/Tail/Deferred/index.html

Module `Tail.Deferred`Source

package async_kernel

Install

Dune Dependency

Authors

Maintainers

Sources

doc/async_kernel/Async_kernel/Tail/Deferred/index.html

Module Tail.DeferredSource

Module `Tail.Deferred`Source