net.pwall.pipeline

Class AbstractIntObjectPipeline<E,R>

java.lang.Object

net.pwall.pipeline.BaseAbstractAcceptor<R>

net.pwall.pipeline.AbstractIntAcceptor<R>

net.pwall.pipeline.AbstractIntObjectPipeline<E,R>

Type Parameters:

E - the emitted (downstream) value type

R - the result type

All Implemented Interfaces:

AutoCloseable, IntConsumer, BaseAcceptor<R>, BasePipeline<R>, IntAcceptor<R>, IntObjectPipeline<E,R>

Direct Known Subclasses:

LinePipeline

public abstract class AbstractIntObjectPipeline<E,R>
extends AbstractIntAcceptor<R>
implements IntObjectPipeline<E,R>

Abstract base class for IntObjectPipeline implementations.

Author:

Peter Wall

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractIntObjectPipeline(Acceptor<? super E,? extends R> downstream) Construct an AbstractIntObjectPipeline with the given downstream Acceptor.

Method Summary

Modifier and Type	Method and Description
void	close() Close the pipeline.
void	emit(E value) Emit a value to the downstream Acceptor.
void	flush() Propagate the flush operation to the downstream acceptor.
Acceptor<? super E,? extends R>	getDownstream() Get the downstream Acceptor

Methods inherited from class net.pwall.pipeline.AbstractIntAcceptor

accept, accept, acceptInt

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

accept, accept, accept, accept, accept, accept, accept, accept, accept, accept

Methods inherited from interface java.util.function.IntConsumer

andThen

Methods inherited from interface net.pwall.pipeline.BasePipeline

getResult, isComplete, isStageComplete

Methods inherited from interface net.pwall.pipeline.BaseAcceptor

isClosed, safeClose

Constructor Detail

AbstractIntObjectPipeline

protected AbstractIntObjectPipeline(Acceptor<? super E,? extends R> downstream)

Construct an AbstractIntObjectPipeline with the given downstream Acceptor.

Parameters:

downstream - the Acceptor

Method Detail

getDownstream

public Acceptor<? super E,? extends R> getDownstream()

Get the downstream Acceptor

Specified by:

getDownstream in interface BasePipeline<R>

Returns:

the Acceptor

close

public void close()
           throws Exception

Close the pipeline.

Specified by:

close in interface AutoCloseable

Overrides:

close in class BaseAbstractAcceptor<R>

Throws:

Exception - if thrown by the downstream or superclass close() functions

emit

public void emit(E value)

Emit a value to the downstream Acceptor.

Specified by:

emit in interface IntObjectPipeline<E,R>

Parameters:

value - the value to be forwarded

flush

public void flush()

Propagate the flush operation to the downstream acceptor.

Specified by:

flush in interface BaseAcceptor<R>