io.jstuff.pipeline

Class ForkPipeline<A,R>

java.lang.Object

io.jstuff.pipeline.BaseAbstractAcceptor<R>

io.jstuff.pipeline.AbstractAcceptor<A,R>

io.jstuff.pipeline.AbstractPipeline<A,A,R>

io.jstuff.pipeline.ForkPipeline<A,R>

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
ForkPipeline(Acceptor<? super A,? extends R> downstream1, Acceptor<? super A,? extends R> downstream2) Construct a Fork with the given downstream Acceptor.

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 io.jstuff.pipeline.AbstractPipeline

close, emit, flush, getDownstream

Methods inherited from class io.jstuff.pipeline.AbstractAcceptor

accept, accept

Methods inherited from class io.jstuff.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 io.jstuff.pipeline.Acceptor

accept, accept, accept, accept, accept

Methods inherited from interface java.util.function.Consumer

andThen

Methods inherited from interface io.jstuff.pipeline.BasePipeline

getResult, isComplete, isStageComplete

Methods inherited from interface io.jstuff.pipeline.BaseAcceptor

isClosed, safeClose

Constructor Detail

ForkPipeline

public ForkPipeline(Acceptor<? super A,? extends R> downstream1,
                    Acceptor<? super A,? extends R> downstream2)

Construct a Fork with the given downstream Acceptor.

Parameters:

downstream1 - the Acceptor

downstream2 - the Acceptor

Method Detail

acceptObject

public void acceptObject(A value)

Description copied from class: AbstractAcceptor

Accept a value, after closed check and test for end of data. Implementing classes must supply an implementation of this method.

Specified by:

acceptObject in class AbstractAcceptor<A,R>

Parameters:

value - the input value