reactor.core.composable.spec

Class Promises

java.lang.Object

reactor.core.composable.spec.Promises

public abstract class Promises
extends java.lang.Object

Helper methods for creating Deferred instances, backed by a Promise.

Constructor Summary

Constructors

Constructor and Description
Promises()

Method Summary

Modifier and Type	Method and Description
static <T> Promise<T>	any(java.util.Collection<? extends Promise<T>> promises) Pick the first result coming from any of the given promises and populate a new Promise.
static <T> Promise<T>	any(Deferred<T,Promise<T>>... promises) Pick the first result coming from any of the given promises and populate a new Promise.
static <T> Promise<T>	any(Promise<T>... promises) Pick the first result coming from any of the given promises and populate a new Promise.
static <T> DeferredPromiseSpec<T>	defer() Create a Deferred backed by a Promise.
static <T> Deferred<T,Promise<T>>	defer(Environment env) Create a Deferred backed by a Promise.
static <T> Deferred<T,Promise<T>>	defer(Environment env, Dispatcher dispatcher) Create a Deferred backed by a Promise.
static <T> Deferred<T,Promise<T>>	defer(Environment env, java.lang.String dispatcher) Create a Deferred backed by a Promise.
static <T> PromiseSpec<T>	error(java.lang.Throwable error) Create a Deferred backed by a Promise and use the given error to complete the Promise immediately.
static <T> Promise<T>	next(Composable<T> composable) Consume the next value of the given Composable and fulfill the returned Promise on the next value.
static <T> PromiseSpec<T>	success(T value) Create a Deferred backed by a Promise and use the given value to complete the Promise immediately.
static <T> PromiseSpec<T>	task(Supplier<T> supplier) Create a Deferred backed by a Promise and producing the value for the Promise using the given supplier.
static <T> Promise<java.util.List<T>>	when(java.util.Collection<? extends Promise<T>> promises) Aggregate given promises into a new a Promise that will be fulfilled when all of the given Promise Promises have been fulfilled.
static <T> Promise<java.util.List<T>>	when(Deferred<T,Promise<T>>... promises) Merge given deferred promises into a new a Promise that will be fulfilled when all of the given Deferred Deferreds have been fulfilled.
static <T> Promise<java.util.List<T>>	when(Promise<T>... promises) Merge given promises into a new a Promise that will be fulfilled when all of the given Promise Promises have been fulfilled.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Promises

public Promises()

Method Detail

defer

public static <T> Deferred<T,Promise<T>> defer(Environment env)

Create a Deferred backed by a Promise.

Type Parameters:

T - type of the expected value

Parameters:

env - the Environment to use

Returns:

a new Deferred

defer

public static <T> Deferred<T,Promise<T>> defer(Environment env,
                                               java.lang.String dispatcher)

Create a Deferred backed by a Promise.

Type Parameters:

T - type of the expected value

Parameters:

env - the Environment to use

dispatcher - the name of the Dispatcher to use

Returns:

a new Deferred

defer

public static <T> Deferred<T,Promise<T>> defer(Environment env,
                                               Dispatcher dispatcher)

Create a Deferred backed by a Promise.

Type Parameters:

T - type of the expected value

Parameters:

env - the Environment to use

dispatcher - the Dispatcher to use

Returns:

a new Deferred

defer

public static <T> DeferredPromiseSpec<T> defer()

Create a Deferred backed by a Promise.

Type Parameters:

T - type of the expected value

Returns:

A DeferredPromiseSpec.

task

public static <T> PromiseSpec<T> task(Supplier<T> supplier)

Create a Deferred backed by a Promise and producing the value for the Promise using the given supplier.

Type Parameters:

T - type of the expected value

Parameters:

supplier - Supplier that will produce the value

Returns:

A PromiseSpec.

success

public static <T> PromiseSpec<T> success(T value)

Create a Deferred backed by a Promise and use the given value to complete the Promise immediately.

Type Parameters:

T - the type of the value

Parameters:

value - the value to complete the Promise with

Returns:

A PromiseSpec that will produce a Promise that is completed with the given value

error

public static <T> PromiseSpec<T> error(java.lang.Throwable error)

Create a Deferred backed by a Promise and use the given error to complete the Promise immediately.

Type Parameters:

T - the type of the value

Parameters:

error - the error to complete the Promise with

Returns:

A PromiseSpec that will produce a Promise that is completed with the given error

when

public static <T> Promise<java.util.List<T>> when(Promise<T>... promises)

Merge given promises into a new a Promise that will be fulfilled when all of the given Promise Promises have been fulfilled.

Type Parameters:

T - The type of the function result.

Parameters:

promises - The promises to use.

Returns:

a Promise.

when

public static <T> Promise<java.util.List<T>> when(Deferred<T,Promise<T>>... promises)

Merge given deferred promises into a new a Promise that will be fulfilled when all of the given Deferred Deferreds have been fulfilled.

Type Parameters:

T - The type of the function result.

Parameters:

promises - The promises to use.

Returns:

a Promise.

when

public static <T> Promise<java.util.List<T>> when(java.util.Collection<? extends Promise<T>> promises)

Aggregate given promises into a new a Promise that will be fulfilled when all of the given Promise Promises have been fulfilled.

Type Parameters:

T - The type of the function result.

Parameters:

promises - The promises to use.

Returns:

a DeferredPromiseSpec.

any

public static <T> Promise<T> any(Deferred<T,Promise<T>>... promises)

Pick the first result coming from any of the given promises and populate a new Promise.

Type Parameters:

T - The type of the function result.

Parameters:

promises - The deferred promises to use.

Returns:

a Promise.

any

public static <T> Promise<T> any(Promise<T>... promises)

Pick the first result coming from any of the given promises and populate a new Promise.

Type Parameters:

T - The type of the function result.

Parameters:

promises - The deferred promises to use.

Returns:

a Promise.

any

public static <T> Promise<T> any(java.util.Collection<? extends Promise<T>> promises)

Pick the first result coming from any of the given promises and populate a new Promise.

Type Parameters:

T - The type of the function result.

Parameters:

promises - The promises to use.

Returns:

a DeferredStreamSpec.

next

public static <T> Promise<T> next(Composable<T> composable)

Consume the next value of the given Composable and fulfill the returned Promise on the next value.

Type Parameters:

T - type of the value

Parameters:

composable - the Composable to consume the next value from

Returns:

a Promise that will be fulfilled with the next value coming into the given Composable