reactor.core.composable.spec

Class DeferredPromiseSpec<T>

java.lang.Object

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

reactor.core.composable.spec.ComposableSpec<DeferredPromiseSpec<T>,Deferred<T,Promise<T>>>

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

Type Parameters:

T - The type of the value that the promise will accept

All Implemented Interfaces:

Supplier<Deferred<T,Promise<T>>>

public final class DeferredPromiseSpec<T>
extends ComposableSpec<DeferredPromiseSpec<T>,Deferred<T,Promise<T>>>

A helper class for specifying a Deferred Promise.

Constructor Summary

Constructors

Constructor and Description
DeferredPromiseSpec()

Method Summary

Modifier and Type	Method and Description
protected Deferred<T,Promise<T>>	createComposable(Environment env, Observable observable, Tuple2<Selector,java.lang.Object> accept)
DeferredPromiseSpec<T>	link(Composable<?> parent) Configures the promise to have the given parent

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

DeferredPromiseSpec

public DeferredPromiseSpec()

Method Detail

link

public DeferredPromiseSpec<T> link(Composable<?> parent)

Configures the promise to have the given parent

Parameters:

parent - The parent for the promise that's being configured

Returns:

this

createComposable

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

Specified by:

createComposable in class ComposableSpec<DeferredPromiseSpec<T>,Deferred<T,Promise<T>>>