Package org.comroid.mutatio.pump

Class BasicPump<O,T>

java.lang.Object

org.comroid.mutatio.pipe.BasicPipe<O,T>

org.comroid.mutatio.pump.BasicPump<O,T>

All Implemented Interfaces:

java.lang.AutoCloseable, java.util.function.Consumer<O>, org.comroid.api.Disposable, org.comroid.api.ExecutorBound, Pipe<O,T>, Pipeable<T>, Pump<O,T>, ReferenceIndex<T>

public class BasicPump<O,T>
extends BasicPipe<O,T>
implements Pump<O,T>

Nested Class Summary

Nested classes/interfaces inherited from interface org.comroid.api.Disposable

org.comroid.api.Disposable.Basic, org.comroid.api.Disposable.Container, org.comroid.api.Disposable.MultipleExceptions

Nested classes/interfaces inherited from interface org.comroid.mutatio.pipe.Pipeable

Pipeable.From<T>

Nested classes/interfaces inherited from interface org.comroid.mutatio.ref.ReferenceIndex

ReferenceIndex.Support

Field Summary

Fields inherited from class org.comroid.mutatio.pipe.BasicPipe

AUTOEMPTY_DISABLED, refs

Constructor Summary

Constructors

Constructor	Description
BasicPump(java.util.concurrent.Executor executor, ReferenceIndex<O> old)
BasicPump(java.util.concurrent.Executor executor, ReferenceIndex<O> old, StageAdapter<O,T> adapter)
BasicPump(ReferenceIndex<O> old)

Method Summary

Modifier and Type	Method	Description
void	accept(O it)
<R> Pump<T,R>	addStage(java.util.concurrent.Executor executor, StageAdapter<T,R> stage)
<R> Pump<T,R>	addStage(StageAdapter<T,R> stage)
java.util.concurrent.Executor	getExecutor()

Methods inherited from class org.comroid.mutatio.pipe.BasicPipe

add, addChildren, clear, getAdapter, getChildren, getReference, pipe, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Methods inherited from interface org.comroid.api.Disposable

addChildren, close, closeContainer, dispose, disposeThrow, getChildren

Methods inherited from interface org.comroid.mutatio.pipe.Pipe

distinct, filter, findAny, findFirst, flatMap, forEach, getAdapter, isSorted, limit, map, peek, pump, remove, skip, sorted, sorted, span, unwrap

Methods inherited from interface org.comroid.mutatio.pipe.Pipeable

pump

Methods inherited from interface org.comroid.mutatio.ref.ReferenceIndex

add, clear, get, getReference, pipe, requireNonNull, requireNonNull, size, stream, subset, subset, wrap

Constructor Detail

BasicPump

public BasicPump(ReferenceIndex<O> old)

BasicPump

public BasicPump(java.util.concurrent.Executor executor,
                 ReferenceIndex<O> old)

BasicPump

public BasicPump(java.util.concurrent.Executor executor,
                 ReferenceIndex<O> old,
                 StageAdapter<O,T> adapter)

Method Detail

getExecutor

public java.util.concurrent.Executor getExecutor()

Specified by:

getExecutor in interface org.comroid.api.ExecutorBound

addStage

public <R> Pump<T,R> addStage(StageAdapter<T,R> stage)

Specified by:

addStage in interface Pipe<O,T>

Specified by:

addStage in interface Pump<O,T>

Overrides:

addStage in class BasicPipe<O,T>

addStage

public <R> Pump<T,R> addStage(java.util.concurrent.Executor executor,
                                    StageAdapter<T,R> stage)

Specified by:

addStage in interface Pump<O,T>

accept

public void accept(O it)

Specified by:

accept in interface java.util.function.Consumer<O>

Specified by:

accept in interface Pipe<O,T>

Overrides:

accept in class BasicPipe<O,T>