net.pwall.util.pipeline

Interface Pipeline<A,E,R>

Type Parameters:

A - the accepted (input) value type

E - the emitted (downstream) value type

R - the result type

All Superinterfaces:

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

All Known Implementing Classes:

AbstractPipeline

public interface Pipeline<A,E,R>
extends Acceptor<A,R>

A pipeline that accepts and emits values of the specified types.

Author:

Peter Wall

Method Summary

Modifier and Type	Method and Description
void	emit(E value) Emit a value, that is, forward a value to the downstream acceptor.

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

accept

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

flush, getResult, isClosed, isComplete

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

emit

void emit(E value)
   throws Exception

Emit a value, that is, forward a value to the downstream acceptor.

Parameters:

value - the value

Throws:

Exception - if thrown by a close() method