io.jstuff.pipeline

Class AbstractAcceptor<A,R>

java.lang.Object

io.jstuff.pipeline.BaseAbstractAcceptor<R>

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

Type Parameters:

A - the accepted (input) value type

R - the result type

All Implemented Interfaces:

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

Direct Known Subclasses:

AbstractObjectIntPipeline, AbstractPipeline, Counter, Fold, 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... values) Accept a sequence of values, supplied as vararg parameters.
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 io.jstuff.pipeline.BaseAbstractAcceptor

close, 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

Methods inherited from interface io.jstuff.pipeline.BaseAcceptor

flush, getResult, isClosed, isComplete, safeClose

Methods inherited from interface java.lang.AutoCloseable

close

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

AbstractAcceptor

public AbstractAcceptor()

Method Detail

accept

public void accept(A value)

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>

Specified by:

accept in interface Consumer<A>

Parameters:

value - the input value

acceptObject

public abstract void acceptObject(A value)

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

accept

@SafeVarargs
public final void accept(A... values)

Accept a sequence of values, supplied as vararg parameters.

Parameters:

values - the input values