C
- the consumed generic typeP
- the produced generic typepublic abstract class Pipe<C,P> extends Object implements Filter<C,P,InvocationContext<P>>
Modifier and Type | Field and Description |
---|---|
protected InvocationContext<P> |
context
.
|
Constructor and Description |
---|
Pipe() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close pipe.
|
void |
flush()
Flush pipe.
|
Class<C> |
getConsumedType()
Returns the class of the element generic type.
|
Class<P> |
getProducedType()
Returns the class of the produced type.
|
void |
open()
Open pipe.
|
void |
open(InvocationContext<P> consumer)
Open the producer with the specified consumer.
|
void |
provide(C element)
Provide an element.
|
protected InvocationContext<P> context
public Pipe()
public final Class<P> getProducedType()
Producer
getProducedType
in interface Producer<P,InvocationContext<P>>
public final Class<C> getConsumedType()
Consumer
getConsumedType
in interface Consumer<C>
public void open(InvocationContext<P> consumer) throws Exception
Producer
public void provide(C element) throws Exception
Consumer
public void flush() throws IOException
flush
in interface Consumer<C>
IOException
- any io exceptionCopyright © 2015 eXo Platform SAS. All Rights Reserved.