io.jstuff.pipeline

Class AbstractIntPipeline<R>

java.lang.Object

io.jstuff.pipeline.BaseAbstractAcceptor<R>

io.jstuff.pipeline.AbstractIntAcceptor<R>

io.jstuff.pipeline.AbstractIntPipeline<R>

Type Parameters:

R - the result type

All Implemented Interfaces:

BaseAcceptor<R>, BasePipeline<R>, IntAcceptor<R>, IntPipeline<R>, AutoCloseable, IntConsumer

Direct Known Subclasses:

DecoderBase, EncoderBase, ErrorStrategyBase, IntFilter, SwitchableDecoder, UTF16BE_UTF16, UTF16LE_UTF16, UTF32BE_CodePoint, UTF32LE_CodePoint

public abstract class AbstractIntPipeline<R>
extends AbstractIntAcceptor<R>
implements IntPipeline<R>

Abstract base class for IntPipeline implementations.

Author:

Peter Wall

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractIntPipeline(IntAcceptor<? extends R> downstream) Construct an AbstractIntPipeline with the given downstream IntAcceptor.

Method Summary

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

Methods inherited from class io.jstuff.pipeline.AbstractIntAcceptor

accept, accept, acceptInt

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

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

Methods inherited from interface java.util.function.IntConsumer

andThen

Methods inherited from interface io.jstuff.pipeline.BasePipeline

getResult, isComplete, isStageComplete

Methods inherited from interface io.jstuff.pipeline.BaseAcceptor

isClosed, safeClose

Constructor Detail

AbstractIntPipeline

protected AbstractIntPipeline(IntAcceptor<? extends R> downstream)

Construct an AbstractIntPipeline with the given downstream IntAcceptor.

Parameters:

downstream - the IntAcceptor

Method Detail

getDownstream

public IntAcceptor<? extends R> getDownstream()

Get the downstream IntAcceptor

Specified by:

getDownstream in interface BasePipeline<R>

Returns:

the IntAcceptor

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(int value)

Emit a value to the downstream IntAcceptor.

Specified by:

emit in interface IntPipeline<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>