include Async_kernel.Deferred.Or_error
module Deferred : sig ... end
type 'a t = 'a Core_kernel.Or_error.t Deferred.t
The applicative operations match the behavior of the applicative operations in Or_error
. This means that all
and all_unit
are equivalent to combine_errors
and combine_errors_unit
respectively.
return x = Deferred.return (Ok x)
*
include Core_kernel.Monad.S with type 'a t := 'a t
t >>= f
returns a computation that sequences the computations represented by two monad elements. The resulting computation first does t
to yield a value v
, and then runs the computation returned by f v
.
module Monad_infix : sig ... end
val return : 'a -> 'a t
return v
returns the (trivial) computation that returns v.
ignore_m t
is map t ~f:(fun _ -> ())
. ignore_m
used to be called ignore
, but we decided that was a bad name, because it shadowed the widely used Caml.ignore
. Some monads still do let ignore = ignore_m
for historical reasons.
module Let_syntax : sig ... end
val fail : Core_kernel.Error.t -> _ t
fail error = Deferred.return (Error error)
*
val ok_exn : 'a t -> 'a Deferred.t
These functions are direct analogs of the corresponding Core.Or_error
functions.
val of_exn : exn -> _ t
val of_exn_result : ('a, exn) Core_kernel.Result.t Deferred.t -> 'a t
val error : string -> 'a -> ('a -> Core_kernel.Sexp.t) -> _ t
val error_s : Core_kernel.Sexp.t -> _ t
val error_string : string -> _ t
val errorf : ('a, unit, string, _ t) Core_kernel.format4 -> 'a
val tag_s : 'a t -> tag:Core_kernel.Sexp.t -> 'a t
val tag_arg : 'a t -> string -> 'b -> ('b -> Core_kernel.Sexp.t) -> 'a t
val unimplemented : string -> _ t
find_map_ok l ~f
returns the first value in l
for which f
returns Ok
, otherwise it returns the same error as combine_errors (Deferred.List.map l ~f)
.
val ok_unit : unit t
ok_unit = return ()
val try_with : ?extract_exn:bool -> ?run:[ `Now | `Schedule ] -> ?here:Stdlib.Lexing.position -> ?name:string -> (unit -> 'a Deferred.t) -> 'a t
try_with f
catches exceptions thrown by f
and returns them in the Result.t as an Error.t. try_with_join
is like try_with
, except that f
can throw exceptions or return an Error
directly, without ending up with a nested error; it is equivalent to try_with f >>| Result.join
.
The option extract_exn
is passed along to Monitor.try_with ?extract_exn
and specifies whether or not the monitor exn wrapper should be skipped (extract_exn:true
or kept (extract_exn:false
).
val try_with_join : ?extract_exn:bool -> ?run:[ `Now | `Schedule ] -> ?here:Stdlib.Lexing.position -> ?name:string -> (unit -> 'a t) -> 'a t
module List : Async_kernel.Monad_sequence.S with type 'a monad := 'a t with type 'a t := 'a list
All of the List
functions that take a how
argument treat it the following way:
val repeat_until_finished : 'state -> ('state -> [ `Repeat of 'state | `Finished of 'result ] t) -> 'result t
repeat_until_finished initial_state f
works the just like Deferred.repeat_until_finished
but with the Deferred.Or_error
monad. If f
returns an Or_error.Error
the loop terminates and returns.
module Expect_test_config : sig ... end