Source file promise.ml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
open Picos
open Picos_std_event

type 'a t = 'a Computation.t

let of_value = Computation.returned
let await = Computation.await
let completed = Event.from_computation
let is_running = Computation.is_running

let try_terminate ?callstack t =
  Computation.try_cancel t Control.Terminate
    (Control.get_callstack_opt callstack)

let terminate ?callstack t = try_terminate ?callstack t |> ignore

let terminate_after ?callstack t ~seconds =
  Computation.cancel_after t ~seconds Control.Terminate
    (Control.get_callstack_opt callstack)