org.crsh.stream
Interface Producer<P,C extends Consumer<? super P>>

Type Parameters:

P - the produced element generic type

C - the consumer element generic type

All Known Subinterfaces:

Filter<C,P,CONS>

All Known Implementing Classes:

BaseCommandMatch.BaseInvoker, ClosureInvoker, CommandInvoker, CommandInvokerAdapter, Pipe, PipeLine

public interface Producer<P,C extends Consumer<? super P>>

A producer that produces elements in a specific consumer.

getProducedType

Class<P> getProducedType()

Returns the class of the produced type.

Returns:

the produced type

open

void open(C consumer)
          throws Exception

Open the producer with the specified consumer.

Parameters:

consumer - the consumer

Throws:

Exception - any exception

close

void close()
           throws Exception

Close the producer.

Throws:

Exception - any exception