org.crsh.io
Interface Producer<P,C extends Consumer<P>>

Type Parameters:

P - the produced element generic type

C - the consumer element generic type

All Superinterfaces:

Closeable

All Known Subinterfaces:

CommandInvoker<C,P>, Filter<C,P,CONS>

All Known Implementing Classes:

GroovyScriptCommand, Pipe, PipeCommandProxy, PipeFilter, PipeFilter.Chunkizer, PipeFilter.Noop, PipeFilter.Sink, PipeLine

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

extends Closeable

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)

Open the producer with the specified consumer.

Parameters:

consumer - the consumer

close

void close()
           throws IOException

Close the producer.

Specified by:

close in interface Closeable

Throws:

IOException