package ocsipersist-pgsql

  1. Overview
  2. Docs

Module Ocsipersist.Lwt_threadSource

include module type of struct include Lwt end
Sourcetype 'a t = 'a Lwt.t
Sourcetype 'a u = 'a Lwt.u
Sourceval wait : unit -> 'a t * 'a u
Sourceval wakeup_later : 'a u -> 'a -> unit
Sourceval wakeup_later_exn : 'a u -> exn -> unit
Sourceval return : 'a -> 'a t
Sourceval fail : exn -> 'a t
Sourceval bind : 'a t -> ('a -> 'b t) -> 'b t
Sourceval reraise : exn -> 'a
Sourceval catch : (unit -> 'a t) -> (exn -> 'a t) -> 'a t
Sourceval finalize : (unit -> 'a t) -> (unit -> unit t) -> 'a t
Sourceval try_bind : (unit -> 'a t) -> ('a -> 'b t) -> (exn -> 'b t) -> 'b t
Sourceval dont_wait : (unit -> unit t) -> (exn -> unit) -> unit
Sourceval async : (unit -> unit t) -> unit
Sourceval async_exception_hook : (exn -> unit) ref
Sourceval both : 'a t -> 'b t -> ('a * 'b) t
Sourceval join : unit t list -> unit t
Sourceval all : 'a t list -> 'a list t
Sourceval pick : 'a t list -> 'a t
Sourceval choose : 'a t list -> 'a t
Sourceval npick : 'a t list -> 'a list t
Sourceval nchoose : 'a t list -> 'a list t
Sourceval nchoose_split : 'a t list -> ('a list * 'a t list) t
Sourceexception Canceled
Sourceval task : unit -> 'a t * 'a u
Sourceval cancel : 'a t -> unit
Sourceval on_cancel : 'a t -> (unit -> unit) -> unit
Sourceval protected : 'a t -> 'a t
Sourceval no_cancel : 'a t -> 'a t
Sourceval wrap_in_cancelable : 'a t -> 'a t
Sourceval map : ('a -> 'b) -> 'a t -> 'b t
Sourceval on_success : 'a t -> ('a -> unit) -> unit
Sourceval on_failure : 'a t -> (exn -> unit) -> unit
Sourceval on_termination : 'a t -> (unit -> unit) -> unit
Sourceval on_any : 'a t -> ('a -> unit) -> (exn -> unit) -> unit
Sourcemodule Infix = Lwt.Infix
Sourcemodule Let_syntax = Lwt.Let_syntax
Sourcemodule Syntax = Lwt.Syntax
Sourceval return_unit : unit t
Sourceval return_none : 'a option t
Sourceval return_nil : 'a list t
Sourceval return_true : bool t
Sourceval return_false : bool t
Sourceval return_some : 'a -> 'a option t
Sourceval return_ok : 'a -> ('a, 'b) result t
Sourceval return_error : 'e -> ('a, 'e) result t
Sourceval fail_with : string -> 'a t
Sourceval fail_invalid_arg : string -> 'a t
Sourceval of_result : ('a, exn) result -> 'a t
Sourceval wakeup_later_result : 'a u -> ('a, exn) result -> unit
Sourcetype !'a state = 'a Lwt.state =
  1. | Return of 'a
  2. | Fail of exn
  3. | Sleep
Sourceval state : 'a t -> 'a state
Sourcetype 'a key = 'a Lwt.key
Sourceval new_key : unit -> 'a key
Sourceval get : 'a key -> 'a option
Sourceval with_value : 'a key -> 'a option -> (unit -> 'b) -> 'b
Sourceval wakeup : 'a u -> 'a -> unit
Sourceval wakeup_exn : 'a u -> exn -> unit
Sourceval wakeup_result : 'a u -> ('a, exn) result -> unit
Sourceval add_task_r : 'a u Lwt_sequence.t -> 'a t
  • deprecated Deprecated because Lwt_sequence is an implementation detail of Lwt. See https://github.com/ocsigen/lwt/issues/361
Sourceval add_task_l : 'a u Lwt_sequence.t -> 'a t
  • deprecated Deprecated because Lwt_sequence is an implementation detail of Lwt. See https://github.com/ocsigen/lwt/issues/361
Sourceval pause : unit -> unit t
Sourceval wakeup_paused : unit -> unit
Sourceval paused_count : unit -> int
Sourceval register_pause_notifier : (int -> unit) -> unit
Sourceval abandon_paused : unit -> unit
Sourceval wrap : (unit -> 'a) -> 'a t
Sourceval wrap1 : ('a -> 'b) -> 'a -> 'b t
Sourceval wrap2 : ('a -> 'b -> 'c) -> 'a -> 'b -> 'c t
Sourceval wrap3 : ('a -> 'b -> 'c -> 'd) -> 'a -> 'b -> 'c -> 'd t
Sourceval wrap4 : ('a -> 'b -> 'c -> 'd -> 'e) -> 'a -> 'b -> 'c -> 'd -> 'e t
Sourceval wrap5 : ('a -> 'b -> 'c -> 'd -> 'e -> 'f) -> 'a -> 'b -> 'c -> 'd -> 'e -> 'f t
Sourceval wrap6 : ('a -> 'b -> 'c -> 'd -> 'e -> 'f -> 'g) -> 'a -> 'b -> 'c -> 'd -> 'e -> 'f -> 'g t
Sourceval wrap7 : ('a -> 'b -> 'c -> 'd -> 'e -> 'f -> 'g -> 'h) -> 'a -> 'b -> 'c -> 'd -> 'e -> 'f -> 'g -> 'h t
Sourceval (>>=) : 'a t -> ('a -> 'b t) -> 'b t
Sourceval (>|=) : 'a t -> ('a -> 'b) -> 'b t
Sourceval (<?>) : 'a t -> 'a t -> 'a t
Sourceval (<&>) : unit t -> unit t -> unit t
Sourceval (=<<) : ('a -> 'b t) -> 'a t -> 'b t
Sourceval (=|<) : ('a -> 'b) -> 'a t -> 'b t
Sourceval is_sleeping : 'a t -> bool
Sourceval ignore_result : 'a t -> unit
Sourcemodule Exception_filter = Lwt.Exception_filter
Sourceval poll : 'a t -> 'a option
Sourceval apply : ('a -> 'b t) -> 'a -> 'b t
Sourceval backtrace_bind : (exn -> exn) -> 'a t -> ('a -> 'b t) -> 'b t
Sourceval backtrace_catch : (exn -> exn) -> (unit -> 'a t) -> (exn -> 'a t) -> 'a t
Sourceval backtrace_finalize : (exn -> exn) -> (unit -> 'a t) -> (unit -> unit t) -> 'a t
Sourceval backtrace_try_bind : (exn -> exn) -> (unit -> 'a t) -> ('a -> 'b t) -> (exn -> 'b t) -> 'b t
Sourceval abandon_wakeups : unit -> unit
Sourceval debug_state_is : 'a state -> 'a t -> bool t
Sourceval close_in : 'a Lwt_io.channel -> unit Lwt.t
Sourceval really_input : Lwt_io.input_channel -> bytes -> int -> int -> unit Lwt.t
Sourceval input_binary_int : Lwt_io.input_channel -> int Lwt.t
Sourceval input_char : Lwt_io.input_channel -> char Lwt.t
Sourceval output_string : Lwt_io.output_channel -> string -> unit Lwt.t
Sourceval output_binary_int : Lwt_io.output_channel -> int -> unit Lwt.t
Sourceval output_char : Lwt_io.output_channel -> char -> unit Lwt.t
Sourceval flush : Lwt_io.output_channel -> unit Lwt.t
Sourceval open_connection : Unix.sockaddr -> (Lwt_io.input_channel * Lwt_io.output_channel) Lwt.t
Sourcetype out_channel = Lwt_io.output_channel
Sourcetype in_channel = Lwt_io.input_channel