net.pwall.pipeline

Class Filter<A,R>

java.lang.Object

net.pwall.pipeline.BaseAbstractAcceptor<R>

net.pwall.pipeline.AbstractAcceptor<A,R>

net.pwall.pipeline.AbstractPipeline<A,A,R>

net.pwall.pipeline.Filter<A,R>

Type Parameters:

A - the accepted (input) value type (the emitted type is the same)

R - the result type

All Implemented Interfaces:

AutoCloseable, Consumer<A>, Acceptor<A,R>, BaseAcceptor<R>, BasePipeline<R>, Pipeline<A,A,R>

public class Filter<A,R>
extends AbstractPipeline<A,A,R>

A pipeline that filters objects based on a specified predicate.

Author:

Peter Wall

Constructor Summary

Constructors

Constructor and Description
Filter(Acceptor<? super A,? extends R> downstream, Predicate<A> predicate) Construct a Filter with the given downstream Acceptor and Predicate.

Method Summary

Modifier and Type	Method and Description
void	acceptObject(A value) Accept a value, after closed check and test for end of data.

Methods inherited from class net.pwall.pipeline.AbstractPipeline

close, emit, flush, getDownstream

Methods inherited from class net.pwall.pipeline.AbstractAcceptor

accept, accept

Methods inherited from class net.pwall.pipeline.BaseAbstractAcceptor

isClosed

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.pwall.pipeline.Acceptor

accept, accept, accept, accept, accept

Methods inherited from interface java.util.function.Consumer

andThen

Methods inherited from interface net.pwall.pipeline.BasePipeline

getResult, isComplete, isStageComplete

Methods inherited from interface net.pwall.pipeline.BaseAcceptor

isClosed, safeClose

Constructor Detail

Filter

public Filter(Acceptor<? super A,? extends R> downstream,
              Predicate<A> predicate)

Construct a Filter with the given downstream Acceptor and Predicate.

Parameters:

downstream - the Acceptor

predicate - the Predicate

Method Detail

acceptObject

public void acceptObject(A value)

Accept a value, after closed check and test for end of data. Emit the value if the predicate returns true for this value.

Specified by:

acceptObject in class AbstractAcceptor<A,R>

Parameters:

value - the input value