C
- Type of processing contextpublic class ChainProcessor<C extends ProcessingContext> extends Object implements Processor<C>
Constructor and Description |
---|
ChainProcessor(ProcessingStage<C> chainHead,
ExecutorService executor)
Create processor for a given processing chain.
|
ChainProcessor(ProcessingStage<C> chainHead,
ExecutorService executor,
ContextFinalizer<C> finalizer)
Create processor for a given processing chain.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<?> |
process(C context,
ListenerSource<C> listenerSource)
Begin asynchronous processing of a given context.
|
public ChainProcessor(ProcessingStage<C> chainHead, ExecutorService executor)
chainHead
- First stageexecutor
- Asynchronous facility to use for executing the processing chainpublic ChainProcessor(ProcessingStage<C> chainHead, ExecutorService executor, ContextFinalizer<C> finalizer)
chainHead
- First stageexecutor
- Asynchronous facility to use for executing the processing chainfinalizer
- Context finalizer, that will be called,
when torrent processing completes normally or terminates abruptly due to errorpublic CompletableFuture<?> process(C context, ListenerSource<C> listenerSource)
Processor
process
in interface Processor<C extends ProcessingContext>
context
- Processing context, that contains all necessary data to begin the processinglistenerSource
- ListenersCopyright © 2016–2021. All rights reserved.