Package org.comroid.mutatio.pump

Interface Pump<O,T>

All Superinterfaces:

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

All Known Implementing Classes:

BasicPump

public interface Pump<O,T>
extends Pipe<O,T>, org.comroid.api.ExecutorBound

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

Method Summary

Modifier and Type	Method	Description
<R> Pump<T,R>	addStage(java.util.concurrent.Executor executor, StageAdapter<T,R> stage)
<R> Pump<T,R>	addStage(StageAdapter<T,R> stage)
static <T> Pump<T,T>	create()
static <T> Pump<T,T>	create(java.util.concurrent.Executor executor)
static <T> Pump<T,T>	of(java.util.Collection<T> collection)

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.api.ExecutorBound

getExecutor

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

accept, 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

Method Detail

create

static <T> Pump<T,T> create()

create

static <T> Pump<T,T> create(java.util.concurrent.Executor executor)

of

static <T> Pump<T,T> of(java.util.Collection<T> collection)

addStage

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

Specified by:

addStage in interface Pipe<O,T>

addStage

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