net.pwall.util.pipeline

Class AbstractAcceptor<A,R>

java.lang.Object

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

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

Type Parameters:

A - the accepted (input) value type

R - the result type

All Implemented Interfaces:

AutoCloseable, Acceptor<A,R>, BaseAcceptor<R>

Direct Known Subclasses:

AbstractPipeline, ListAcceptor, SetAcceptor

public abstract class AbstractAcceptor<A,R>
extends BaseAbstractAcceptor<R>
implements Acceptor<A,R>

Abstract implementation of Acceptor.

Author:

Peter Wall

Constructor Summary

Constructors

Constructor and Description
AbstractAcceptor()

Method Summary

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

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

close, getResult, 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.BaseAcceptor

flush, getResult, isClosed, isComplete

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

AbstractAcceptor

public AbstractAcceptor()

Method Detail

accept

public void accept(A value)
            throws Exception

Accept an object. Check for pipeline already closed, and handle end of data. This assumes that null is used to indicate end of data; if that is not the case this method must be overridden or an alternative implementation of Acceptor used.

Specified by:

accept in interface Acceptor<A,R>

Parameters:

value - the input value

Throws:

Exception - if thrown by a close() method

acceptObject

public abstract void acceptObject(A value)
                           throws Exception

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

Parameters:

value - the input value

Throws:

Exception - if thrown by a close() method