Package org.comroid.mutatio.pipe

Interface Pipe<I,O>

All Superinterfaces:

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

All Known Subinterfaces:

Pump<O,T>

All Known Implementing Classes:

BasicPipe, BasicPump, SortedResultingPipe

public interface Pipe<I,O>
extends ReferenceIndex<O>, java.util.function.Consumer<I>, org.comroid.api.Disposable

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
default void	accept(I input)
<R> Pipe<O,R>	addStage(StageAdapter<O,R> stage)
static <T> Pipe<T,T>	create()
default Pipe<O,O>	distinct()
default Pipe<O,O>	filter(java.util.function.Predicate<? super O> predicate)
default @NotNull Processor<O>	findAny()
default @NotNull Processor<O>	findFirst()
default <R> Pipe<O,R>	flatMap(java.util.function.Function<? super O,? extends Reference<? extends R>> mapper)
default void	forEach(java.util.function.Consumer<? super O> action)
StageAdapter<I,O>	getAdapter()
default boolean	isSorted()
default Pipe<O,O>	limit(long maxSize)
default <R> Pipe<O,R>	map(java.util.function.Function<? super O,? extends R> mapper)
static <T> Pipe<T,T>	of(java.util.Collection<T> collection)
default Pipe<O,O>	peek(java.util.function.Consumer<? super O> action)
default Pump<I,O>	pump(java.util.concurrent.Executor executor)
default boolean	remove(O item)
default Pipe<O,O>	skip(long skip)
default Pipe<O,O>	sorted()
default Pipe<O,O>	sorted(java.util.Comparator<? super O> comparator)
default Span<O>	span()
default java.util.List<O>	unwrap()

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

getAdapter

StageAdapter<I,O> getAdapter()

isSorted

default boolean isSorted()

create

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

of

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

unwrap

default java.util.List<O> unwrap()

Specified by:

unwrap in interface ReferenceIndex<I>

addStage

<R> Pipe<O,R> addStage(StageAdapter<O,R> stage)

filter

default Pipe<O,O> filter(java.util.function.Predicate<? super O> predicate)

map

default <R> Pipe<O,R> map(java.util.function.Function<? super O,? extends R> mapper)

flatMap

default <R> Pipe<O,R> flatMap(java.util.function.Function<? super O,? extends Reference<? extends R>> mapper)

distinct

default Pipe<O,O> distinct()

peek

default Pipe<O,O> peek(java.util.function.Consumer<? super O> action)

limit

default Pipe<O,O> limit(long maxSize)

skip

default Pipe<O,O> skip(long skip)

forEach

default void forEach(java.util.function.Consumer<? super O> action)

sorted

default Pipe<O,O> sorted()

sorted

default Pipe<O,O> sorted(java.util.Comparator<? super O> comparator)

findFirst

@NotNull
default @NotNull Processor<O> findFirst()

findAny

@NotNull
default @NotNull Processor<O> findAny()

remove

default boolean remove(O item)
                throws java.lang.UnsupportedOperationException

Specified by:

remove in interface ReferenceIndex<I>

Throws:

java.lang.UnsupportedOperationException

pump

default Pump<I,O> pump(java.util.concurrent.Executor executor)

Specified by:

pump in interface Pipeable<I>

accept

default void accept(I input)

Specified by:

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

span

default Span<O> span()