reactor.core.composable.spec

Class PromiseSpec<T>

java.lang.Object

reactor.core.spec.support.DispatcherComponentSpec<SPEC,TARGET>

reactor.core.composable.spec.ComposableSpec<PromiseSpec<T>,Promise<T>>

reactor.core.composable.spec.PromiseSpec<T>

Type Parameters:

T - the type of the value that the Promise will contain

All Implemented Interfaces:

Supplier<Promise<T>>

public final class PromiseSpec<T>
extends ComposableSpec<PromiseSpec<T>,Promise<T>>

A helper class for specifying a Promise.

Constructor Summary

Constructors

Constructor and Description
PromiseSpec()

Method Summary

Modifier and Type	Method and Description
protected Promise<T>	createComposable(Environment env, Observable observable, Tuple2<Selector,java.lang.Object> accept)
PromiseSpec<T>	error(java.lang.Throwable error) Configures the promise to have been completed with the given error.
PromiseSpec<T>	success(T value) Configures the promise to have been successfully completed with the given value.
PromiseSpec<T>	supply(Supplier<T> valueSupplier) Configures the promise to have been successfully completed with the value from the given valueSupplier.

Methods inherited from class reactor.core.composable.spec.ComposableSpec

configure

Methods inherited from class reactor.core.spec.support.DispatcherComponentSpec

actorSystem, actorSystem, defaultDispatcher, dispatcher, dispatcher, env, get, synchronousDispatcher

Methods inherited from class java.lang.Object

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

Constructor Detail

PromiseSpec

public PromiseSpec()

Method Detail

success

public PromiseSpec<T> success(T value)

Configures the promise to have been successfully completed with the given value.

Parameters:

value - The value for the promise to contain

Returns:

this

supply

public PromiseSpec<T> supply(Supplier<T> valueSupplier)

Configures the promise to have been successfully completed with the value from the given valueSupplier.

Parameters:

valueSupplier - The supplier of the value for the promise to contain

Returns:

this

error

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

Configures the promise to have been completed with the given error.

Parameters:

error - The error to be held by the Promise

Returns:

this

createComposable

protected Promise<T> createComposable(Environment env,
                                      Observable observable,
                                      Tuple2<Selector,java.lang.Object> accept)

Specified by:

createComposable in class ComposableSpec<PromiseSpec<T>,Promise<T>>