Source file promise.ml

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)