net.pwall.util.pipeline

Class AbstractIntPipeline<R>

java.lang.Object

net.pwall.util.pipeline.BaseAbstractAcceptor<R>

net.pwall.util.pipeline.AbstractIntAcceptor<R>

net.pwall.util.pipeline.AbstractIntPipeline<R>

Type Parameters:

R - the result type

All Implemented Interfaces:

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

Direct Known Subclasses:

ASCII_CodePoint, CodePoint_UTF16, CodePoint_UTF8, DecodingPipeline, SwitchableDecoder, UTF16_CodePoint, UTF8_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.
R	getResult() Get the result object (defaults to the result of the downstream acceptor).
boolean	isComplete() Return true if all sequences in the input are complete, that is, the input is not in the middle of a sequence requiring more data.

Methods inherited from class net.pwall.util.pipeline.AbstractIntAcceptor

accept, acceptInt

Methods inherited from class net.pwall.util.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.util.pipeline.IntAcceptor

accept, accept, accept, accept, accept

Methods inherited from interface net.pwall.util.pipeline.BaseAcceptor

isClosed

Constructor Detail

AbstractIntPipeline

protected AbstractIntPipeline(IntAcceptor<? extends R> downstream)

Construct an AbstractIntPipeline with the given downstream IntAcceptor.

Parameters:

downstream - the IntAcceptor

Method Detail

close

public void close()
           throws Exception

Close the pipeline.

Specified by:

close in interface AutoCloseable

Overrides:

close in class BaseAbstractAcceptor<R>

Throws:

Exception - if the acceptor is not in the "complete" state

emit

public void emit(int value)
          throws Exception

Emit a value to the downstream IntAcceptor.

Specified by:

emit in interface IntPipeline<R>

Parameters:

value - the value to be forwarded

Throws:

Exception - if thrown by a close() method

getResult

public R getResult()

Get the result object (defaults to the result of the downstream acceptor).

Specified by:

getResult in interface BaseAcceptor<R>

Overrides:

getResult in class BaseAbstractAcceptor<R>

Returns:

the result

isComplete

public boolean isComplete()

Return true if all sequences in the input are complete, that is, the input is not in the middle of a sequence requiring more data. The default implementation tests whether the downstream acceptor is complete.

Specified by:

isComplete in interface BaseAcceptor<R>

Returns:

true if the input is in the "complete" state

flush

public void flush()

Propagate the flush operation to the downstream acceptor.

Specified by:

flush in interface BaseAcceptor<R>