reactor.core.composable.spec

Class StreamSpec<T>

java.lang.Object

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

reactor.core.composable.spec.ComposableSpec<StreamSpec<T>,Stream<T>>

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

Type Parameters:

T - The type of values that the stream contains.

All Implemented Interfaces:

Supplier<Stream<T>>

public final class StreamSpec<T>
extends ComposableSpec<StreamSpec<T>,Stream<T>>

A helper class for specifying a bounded Stream. each(java.lang.Iterable<T>) must be called to provide the stream with its values.

Constructor Summary

Constructors

Constructor and Description
StreamSpec()

Method Summary

Modifier and Type	Method and Description
StreamSpec<T>	batchSize(int batchSize) Configures the stream to have the given batchSize.
protected Stream<T>	createComposable(Environment env, Observable observable, Tuple2<Selector,java.lang.Object> accept)
StreamSpec<T>	each(java.lang.Iterable<T> values) Configures the stream to contain the given values.
StreamSpec<T>	generate(Supplier<T> supplier) Configures the stream to pass value from a Supplier on flush.

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

StreamSpec

public StreamSpec()

Method Detail

batchSize

public StreamSpec<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

each

public StreamSpec<T> each(java.lang.Iterable<T> values)

Configures the stream to contain the given values.

Parameters:

values - The stream's values

Returns:

this

generate

public StreamSpec<T> generate(Supplier<T> supplier)

Configures the stream to pass value from a Supplier on flush.

Parameters:

supplier - The stream's value generator

Returns:

this

createComposable

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

Specified by:

createComposable in class ComposableSpec<StreamSpec<T>,Stream<T>>