com.aol.cyclops2.internal.react.stream

Class BaseSimpleReact

java.lang.Object

com.aol.cyclops2.internal.react.stream.BaseSimpleReact

All Implemented Interfaces:

ReactBuilder

public abstract class BaseSimpleReact
extends java.lang.Object
implements ReactBuilder

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseSimpleReact()
protected	BaseSimpleReact(java.util.concurrent.Executor queueService)

Method Summary

Modifier and Type	Method and Description
abstract <U> BaseSimpleReactStream<U>	construct(java.util.stream.Stream s)
<R> BaseSimpleReactStream<R>	from(java.util.Collection<R> collection) Start a reactiveBuffer flow from a Collection using an Iterator
<U> BaseSimpleReactStream<U>	from(java.util.concurrent.CompletableFuture<U>... cf)
<U> BaseSimpleReactStream<U>	from(java.util.concurrent.CompletableFuture<U> cf)
<U> BaseSimpleReactStream<U>	from(java.util.stream.DoubleStream stream) Start a reactiveBuffer dataflow from a reactiveStream.
<U> BaseSimpleReactStream<U>	from(java.util.stream.IntStream stream) Start a reactiveBuffer dataflow from a reactiveStream.
<U> BaseSimpleReactStream<U>	from(java.util.Iterator<U> iterator) Start a reactiveBuffer flow from a JDK Iterator
<U> BaseSimpleReactStream<U>	from(java.util.stream.LongStream stream) Start a reactiveBuffer dataflow from a reactiveStream.
<U> BaseSimpleReactStream<U>	from(java.util.stream.Stream<U> stream) Start a reactiveBuffer dataflow from a reactiveStream.
<U> BaseSimpleReactStream<U>	fromIterable(java.lang.Iterable<U> iter) Start a reactiveBuffer flow from a JDK Iterator
<U> BaseSimpleReactStream<U>	fromStream(java.util.stream.Stream<java.util.concurrent.CompletableFuture<U>> stream) Start a reactiveBuffer dataflow from a reactiveStream of CompletableFutures.
protected abstract java.util.concurrent.Executor	getExecutor()
protected abstract boolean	isAsync()
<U> BaseSimpleReactStream<U>	of(U... array)
BaseSimpleReactStream<java.lang.Integer>	range(int startInclusive, int endExclusive)
<U> BaseSimpleReactStream<U>	react(java.util.Collection<java.util.function.Supplier<U>> actions) Start a reactiveBuffer dataflow with a list of one-off-suppliers
<U> BaseSimpleReactStream<U>	react(java.util.Iterator<java.util.function.Supplier<U>> actions) Start a reactiveBuffer dataflow with a list of one-off-suppliers
<U> BaseSimpleReactStream<U>	react(java.util.stream.Stream<java.util.function.Supplier<U>> actions) Start a reactiveBuffer dataflow with a list of one-off-suppliers
<U> BaseSimpleReactStream<U>	react(java.util.function.Supplier<U>... actions) Start a reactiveBuffer dataflow with an array of one-off-suppliers
protected <U> BaseSimpleReactStream<U>	reactI(java.util.function.Supplier<U>... actions) This internal method has been left protected, so it can be mocked / stubbed as some of the entry points are final
<U> BaseSimpleReactStream<U>	reactIterable(java.lang.Iterable<java.util.function.Supplier<U>> actions) Start a reactiveBuffer dataflow with a list of one-off-suppliers

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseSimpleReact

protected BaseSimpleReact()

BaseSimpleReact

protected BaseSimpleReact(java.util.concurrent.Executor queueService)

Method Detail

getExecutor

protected abstract java.util.concurrent.Executor getExecutor()

isAsync

protected abstract boolean isAsync()

construct

public abstract <U> BaseSimpleReactStream<U> construct(java.util.stream.Stream s)

range

public BaseSimpleReactStream<java.lang.Integer> range(int startInclusive,
                                                      int endExclusive)

from

public <U> BaseSimpleReactStream<U> from(java.util.Iterator<U> iterator)

Start a reactiveBuffer flow from a JDK Iterator

Parameters:

iterator - SimpleReact will iterate over this iterator concurrently to skip the reactiveBuffer dataflow

Returns:

Next stage in the reactiveBuffer flow

from

public <R> BaseSimpleReactStream<R> from(java.util.Collection<R> collection)

Start a reactiveBuffer flow from a Collection using an Iterator

Parameters:

collection - - Collection SimpleReact will iterate over at the skip of the flow

Returns:

Next stage in the reactiveBuffer flow

fromIterable

public <U> BaseSimpleReactStream<U> fromIterable(java.lang.Iterable<U> iter)

Start a reactiveBuffer flow from a JDK Iterator

Parameters:

iter - SimpleReact will iterate over this iterator concurrently to skip the reactiveBuffer dataflow

Returns:

Next stage in the reactiveBuffer flow

fromStream

public <U> BaseSimpleReactStream<U> fromStream(java.util.stream.Stream<java.util.concurrent.CompletableFuture<U>> stream)

Start a reactiveBuffer dataflow from a reactiveStream of CompletableFutures.

Parameters:

stream - of CompletableFutures that will be used to drive the reactiveBuffer dataflow

Returns:

Next stage in the reactiveBuffer flow

from

public <U> BaseSimpleReactStream<U> from(java.util.stream.Stream<U> stream)

Start a reactiveBuffer dataflow from a reactiveStream.

Parameters:

stream - that will be used to drive the reactiveBuffer dataflow

Returns:

Next stage in the reactiveBuffer flow

from

public <U> BaseSimpleReactStream<U> from(java.util.stream.IntStream stream)

Start a reactiveBuffer dataflow from a reactiveStream.

Parameters:

stream - that will be used to drive the reactiveBuffer dataflow

Returns:

Next stage in the reactiveBuffer flow

from

public <U> BaseSimpleReactStream<U> from(java.util.stream.DoubleStream stream)

Start a reactiveBuffer dataflow from a reactiveStream.

Parameters:

stream - that will be used to drive the reactiveBuffer dataflow

Returns:

Next stage in the reactiveBuffer flow

from

public <U> BaseSimpleReactStream<U> from(java.util.stream.LongStream stream)

Start a reactiveBuffer dataflow from a reactiveStream.

Parameters:

stream - that will be used to drive the reactiveBuffer dataflow

Returns:

Next stage in the reactiveBuffer flow

of

public <U> BaseSimpleReactStream<U> of(U... array)

from

public <U> BaseSimpleReactStream<U> from(java.util.concurrent.CompletableFuture<U> cf)

from

public <U> BaseSimpleReactStream<U> from(java.util.concurrent.CompletableFuture<U>... cf)

react

public <U> BaseSimpleReactStream<U> react(java.util.Collection<java.util.function.Supplier<U>> actions)

Start a reactiveBuffer dataflow with a list of one-off-suppliers

Parameters:

actions - List of Suppliers to provide data (and thus events) that downstream jobs will react too

Returns:

Next stage in the reactiveBuffer flow

react

public <U> BaseSimpleReactStream<U> react(java.util.stream.Stream<java.util.function.Supplier<U>> actions)

Start a reactiveBuffer dataflow with a list of one-off-suppliers

Parameters:

actions - Stream of Suppliers to provide data (and thus events) that downstream jobs will react too

Returns:

Next stage in the reactiveBuffer flow

react

public <U> BaseSimpleReactStream<U> react(java.util.Iterator<java.util.function.Supplier<U>> actions)

Start a reactiveBuffer dataflow with a list of one-off-suppliers

Parameters:

actions - Iterator over Suppliers to provide data (and thus events) that downstream jobs will react too

Returns:

Next stage in the reactiveBuffer flow

reactIterable

public <U> BaseSimpleReactStream<U> reactIterable(java.lang.Iterable<java.util.function.Supplier<U>> actions)

Start a reactiveBuffer dataflow with a list of one-off-suppliers

Parameters:

actions - Stream of Suppliers to provide data (and thus events) that downstream jobs will react too

Returns:

Next stage in the reactiveBuffer flow

react

public <U> BaseSimpleReactStream<U> react(java.util.function.Supplier<U>... actions)

Start a reactiveBuffer dataflow with an array of one-off-suppliers

Parameters:

actions - Array of Suppliers to provide data (and thus events) that downstream jobs will react too

Returns:

Next stage in the reactiveBuffer flow

reactI

protected <U> BaseSimpleReactStream<U> reactI(java.util.function.Supplier<U>... actions)

This internal method has been left protected, so it can be mocked / stubbed as some of the entry points are final