reactor.core.composable.spec

Class DeferredStreamSpec<T>

java.lang.Object

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

reactor.core.composable.spec.ComposableSpec<DeferredStreamSpec<T>,Deferred<T,Stream<T>>>

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

Type Parameters:

T - The type of values that the stream will contain

All Implemented Interfaces:

Supplier<Deferred<T,Stream<T>>>

public final class DeferredStreamSpec<T>
extends ComposableSpec<DeferredStreamSpec<T>,Deferred<T,Stream<T>>>

A helper class for specifying a Deferred Stream.

Constructor Summary

Constructors

Constructor and Description
DeferredStreamSpec()

Method Summary

Modifier and Type	Method and Description
DeferredStreamSpec<T>	batchSize(int batchSize) Configures the stream to have the given batchSize.
protected Deferred<T,Stream<T>>	createComposable(Environment env, Observable observable, Tuple2<Selector,java.lang.Object> accept)

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

DeferredStreamSpec

public DeferredStreamSpec()

Method Detail

batchSize

public DeferredStreamSpec<T> batchSize(int batchSize)

Configures the stream to have the given batchSize. A value of -1, which is the default configuration, configures the stream to not be batched.

Parameters:

batchSize - The batch size of the stream

Returns:

this

createComposable

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

Specified by:

createComposable in class ComposableSpec<DeferredStreamSpec<T>,Deferred<T,Stream<T>>>