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.


Method Summary
 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


Copyright © 2015 eXo Platform SAS. All Rights Reserved.