reactor.core.composable.spec

Class ComposableSpec<SPEC extends ComposableSpec<SPEC,TARGET>,TARGET>

java.lang.Object

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

reactor.core.composable.spec.ComposableSpec<SPEC,TARGET>

Type Parameters:

SPEC - The ComposableSpec subclass

TARGET - The type that this spec will create

All Implemented Interfaces:

Supplier<TARGET>

Direct Known Subclasses:

DeferredPromiseSpec, DeferredStreamSpec, PromiseSpec, StreamSpec

public abstract class ComposableSpec<SPEC extends ComposableSpec<SPEC,TARGET>,TARGET>
extends DispatcherComponentSpec<SPEC,TARGET>

A helper class for specifying a bounded Composable.

Constructor Summary

Constructors

Constructor and Description
ComposableSpec()

Method Summary

Modifier and Type	Method and Description
protected TARGET	configure(Dispatcher dispatcher, Environment env)
protected abstract TARGET	createComposable(Environment env, Observable observable, Tuple2<Selector,java.lang.Object> accept)

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

ComposableSpec

public ComposableSpec()

Method Detail

configure

protected TARGET configure(Dispatcher dispatcher,
                           Environment env)

Specified by:

configure in class DispatcherComponentSpec<SPEC extends ComposableSpec<SPEC,TARGET>,TARGET>

createComposable

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