public class InitializeTorrentProcessingStage<C extends TorrentContext> extends TerminateOnErrorProcessingStage<C>
Constructor and Description |
---|
InitializeTorrentProcessingStage(ProcessingStage<C> next,
IPeerConnectionPool connectionPool,
TorrentRegistry torrentRegistry,
DataWorker dataWorker,
IBufferedPieceRegistry bufferedPieceRegistry,
EventSink eventSink,
Config config) |
Modifier and Type | Method and Description |
---|---|
ProcessingEvent |
after() |
protected void |
doExecute(C context)
Perform processing.
|
doExecute
execute
public InitializeTorrentProcessingStage(ProcessingStage<C> next, IPeerConnectionPool connectionPool, TorrentRegistry torrentRegistry, DataWorker dataWorker, IBufferedPieceRegistry bufferedPieceRegistry, EventSink eventSink, Config config)
protected void doExecute(C context)
TerminateOnErrorProcessingStage
doExecute
in class TerminateOnErrorProcessingStage<C extends TorrentContext>
public ProcessingEvent after()
Copyright © 2016–2021. All rights reserved.