|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use PipeStage | |
|---|---|
| jconch.pipeline | |
| jconch.pipeline.impl | |
| Uses of PipeStage in jconch.pipeline |
|---|
| Subclasses of PipeStage in jconch.pipeline | |
|---|---|
class |
Consumer<T>
The base implementation of a pipe that consumes elements without producing anything. |
class |
Processor<IN_T,OUT_T>
A processing pipe in the pipeline. |
class |
Producer<OUT_T>
The base implementation of a pipe that produces new elements to retrieve. |
| Methods in jconch.pipeline with parameters of type PipeStage | |
|---|---|
void |
ThreadingModel.execute(PipeStage toRun)
Wraps the execution of the pipeline in the appropriate threading. |
| Uses of PipeStage in jconch.pipeline.impl |
|---|
| Subclasses of PipeStage in jconch.pipeline.impl | |
|---|---|
class |
ClosureConsumer<T>
A Closure-based implementation of a Consumer. |
class |
CollectionConsumer<T>
A consumer which collects elements into a collection. |
class |
CollectionProducer<T>
A producer which provides elements from a given collection. |
class |
FactoryProducer
A Producer based off of a Factory implementation. |
class |
TransformerProcessor
A Transformer-based implementation of a Processor. |
| Methods in jconch.pipeline.impl with parameters of type PipeStage | |
|---|---|
void |
SpawningThreadingModel.execute(PipeStage toRun)
Spawns a thread that calls execute(). |
void |
SingleThreadThreadingModel.execute(PipeStage toRun)
Spawns a thread, and it keeps executing everything. |
void |
InlineThreadingModel.execute(PipeStage toRun)
Simply calls execute(). |
void |
ExecutorThreadingModel.execute(PipeStage toRun)
Delegates the execution of the argument to the underlying executor. |
void |
ExceptionThreadingModel.execute(PipeStage toRun)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||