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:

ClosureInvoker, CommandInvoker, Pipe, PipeLine

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

A producer that produces elements in a specific consumer.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close the producer.
Class<P>	getProducedType() Returns the class of the produced type.
void	open(C consumer) Open the producer with the specified consumer.

Method Detail

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