Promise

zio.Promise
See thePromise companion object
final class Promise[E, A] extends Serializable

A promise represents an asynchronous variable, of zio.ZIO type, that can be set exactly once, with the ability for an arbitrary number of fibers to suspend (by calling await) and automatically resume when the variable is set.

Promises can be used for building primitive actions whose completions require the coordinated action of multiple fibers, and for building higher-level concurrent or asynchronous structures.

for {
 promise <- Promise.make[Nothing, Int]
 _       <- promise.succeed(42).delay(1.second).fork
 value   <- promise.await // Resumes when forked fiber completes promise
} yield value

Attributes

Companion
object
Graph
Supertypes
trait Serializable
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

def await(implicit trace: Trace): IO[E, A]

Retrieves the value of the promise, suspending the fiber running the action until the result is available.

Retrieves the value of the promise, suspending the fiber running the action until the result is available.

Attributes

def complete(io: IO[E, A])(implicit trace: Trace): UIO[Boolean]

Completes the promise with the result of the specified effect. If the promise has already been completed, the method will produce false.

Completes the promise with the result of the specified effect. If the promise has already been completed, the method will produce false.

Note that Promise.completeWith will be much faster, so consider using that if you do not need to memoize the result of the specified effect.

Attributes

def completeWith(io: IO[E, A])(implicit trace: Trace): UIO[Boolean]

Completes the promise with the specified effect. If the promise has already been completed, the method will produce false.

Completes the promise with the specified effect. If the promise has already been completed, the method will produce false.

Note that since the promise is completed with an effect, the effect will be evaluated each time the value of the promise is retrieved through combinators such as await, potentially producing different results if the effect produces different results on subsequent evaluations. In this case te meaning of the "exactly once" guarantee of Promise is that the promise can be completed with exactly one effect. For a version that completes the promise with the result of an effect see Promise.complete.

Attributes

def die(e: Throwable)(implicit trace: Trace): UIO[Boolean]

Kills the promise with the specified error, which will be propagated to all fibers waiting on the value of the promise.

Kills the promise with the specified error, which will be propagated to all fibers waiting on the value of the promise.

Attributes

def done(e: Exit[E, A])(implicit trace: Trace): UIO[Boolean]

Exits the promise with the specified exit, which will be propagated to all fibers waiting on the value of the promise.

Exits the promise with the specified exit, which will be propagated to all fibers waiting on the value of the promise.

Attributes

def fail(e: E)(implicit trace: Trace): UIO[Boolean]

Fails the promise with the specified error, which will be propagated to all fibers waiting on the value of the promise.

Fails the promise with the specified error, which will be propagated to all fibers waiting on the value of the promise.

Attributes

def failCause(e: Cause[E])(implicit trace: Trace): UIO[Boolean]

Fails the promise with the specified cause, which will be propagated to all fibers waiting on the value of the promise.

Fails the promise with the specified cause, which will be propagated to all fibers waiting on the value of the promise.

Attributes

def interrupt(implicit trace: Trace): UIO[Boolean]

Completes the promise with interruption. This will interrupt all fibers waiting on the value of the promise as by the fiber calling this method.

Completes the promise with interruption. This will interrupt all fibers waiting on the value of the promise as by the fiber calling this method.

Attributes

def interruptAs(fiberId: FiberId)(implicit trace: Trace): UIO[Boolean]

Completes the promise with interruption. This will interrupt all fibers waiting on the value of the promise as by the specified fiber.

Completes the promise with interruption. This will interrupt all fibers waiting on the value of the promise as by the specified fiber.

Attributes

def isDone(implicit trace: Trace): UIO[Boolean]

Checks for completion of this Promise. Produces true if this promise has already been completed with a value or an error and false otherwise.

Checks for completion of this Promise. Produces true if this promise has already been completed with a value or an error and false otherwise.

Attributes

def poll(implicit trace: Trace): UIO[Option[IO[E, A]]]

Checks for completion of this Promise. Returns the result effect if this promise has already been completed or a None otherwise.

Checks for completion of this Promise. Returns the result effect if this promise has already been completed or a None otherwise.

Attributes

def refailCause(e: Cause[E])(implicit trace: Trace): UIO[Boolean]

Fails the promise with the specified cause, which will be propagated to all fibers waiting on the value of the promise. No new stack trace is attached to the cause.

Fails the promise with the specified cause, which will be propagated to all fibers waiting on the value of the promise. No new stack trace is attached to the cause.

Attributes

def succeed(a: A)(implicit trace: Trace): UIO[Boolean]

Completes the promise with the specified value.

Completes the promise with the specified value.

Attributes