Package | Description |
---|---|
bt.processor | |
bt.processor.listener | |
bt.processor.magnet | |
bt.processor.torrent |
Modifier and Type | Class and Description |
---|---|
class |
RoutingProcessingStage<C extends ProcessingContext>
Base class for chained processing stage implementations.
|
class |
TerminateOnErrorProcessingStage<C extends ProcessingContext>
Base processing stage, that terminates processing chain in case of error.
|
Modifier and Type | Method and Description |
---|---|
protected abstract ProcessingStage<C> |
RoutingProcessingStage.doExecute(C context,
ProcessingStage<C> next)
Execute current stage and calculate the next stage.
|
protected ProcessingStage<C> |
TerminateOnErrorProcessingStage.doExecute(C context,
ProcessingStage<C> next) |
ProcessingStage<C> |
ProcessingStage.execute(C context) |
ProcessingStage<C> |
RoutingProcessingStage.execute(C context) |
Modifier and Type | Method and Description |
---|---|
protected abstract ProcessingStage<C> |
RoutingProcessingStage.doExecute(C context,
ProcessingStage<C> next)
Execute current stage and calculate the next stage.
|
protected ProcessingStage<C> |
TerminateOnErrorProcessingStage.doExecute(C context,
ProcessingStage<C> next) |
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.
|
RoutingProcessingStage(ProcessingStage<C> next) |
TerminateOnErrorProcessingStage(ProcessingStage<C> next) |
Modifier and Type | Method and Description |
---|---|
Collection<BiFunction<C,ProcessingStage<C>,ProcessingStage<C>>> |
ListenerSource.getListeners(ProcessingEvent event) |
Collection<BiFunction<C,ProcessingStage<C>,ProcessingStage<C>>> |
ListenerSource.getListeners(ProcessingEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
ListenerSource.addListener(ProcessingEvent event,
BiFunction<C,ProcessingStage<C>,ProcessingStage<C>> listener)
Add processing event listener.
|
void |
ListenerSource.addListener(ProcessingEvent event,
BiFunction<C,ProcessingStage<C>,ProcessingStage<C>> listener)
Add processing event listener.
|
Modifier and Type | Class and Description |
---|---|
class |
FetchMetadataStage |
class |
InitializeMagnetTorrentProcessingStage |
class |
ProcessMagnetTorrentStage |
Constructor and Description |
---|
FetchMetadataStage(ProcessingStage<MagnetContext> next,
IMetadataService metadataService,
TorrentRegistry torrentRegistry,
IPeerRegistry peerRegistry,
EventSink eventSink,
Config config) |
InitializeMagnetTorrentProcessingStage(ProcessingStage<MagnetContext> next,
IPeerConnectionPool connectionPool,
TorrentRegistry torrentRegistry,
DataWorker dataWorker,
IBufferedPieceRegistry bufferedPieceRegistry,
EventSink eventSink,
Config config) |
ProcessMagnetTorrentStage(ProcessingStage<MagnetContext> next,
TorrentRegistry torrentRegistry,
IPeerRegistry peerRegistry,
ITrackerService trackerService,
EventSink eventSink) |
Modifier and Type | Class and Description |
---|---|
class |
ChooseFilesStage<C extends TorrentContext> |
class |
CreateSessionStage<C extends TorrentContext> |
class |
FetchTorrentStage |
class |
InitializeTorrentProcessingStage<C extends TorrentContext> |
class |
ProcessTorrentStage<C extends TorrentContext> |
class |
SeedStage<C extends TorrentContext> |
Constructor and Description |
---|
ChooseFilesStage(ProcessingStage<C> next,
TorrentRegistry torrentRegistry,
Config config) |
CreateSessionStage(ProcessingStage<C> next,
TorrentRegistry torrentRegistry,
EventSource eventSource,
IConnectionSource connectionSource,
IMessageDispatcher messageDispatcher,
Set<Object> messagingAgents,
Config config) |
FetchTorrentStage(ProcessingStage<TorrentContext> next,
EventSink eventSink) |
InitializeTorrentProcessingStage(ProcessingStage<C> next,
IPeerConnectionPool connectionPool,
TorrentRegistry torrentRegistry,
DataWorker dataWorker,
IBufferedPieceRegistry bufferedPieceRegistry,
EventSink eventSink,
Config config) |
ProcessTorrentStage(ProcessingStage<C> next,
TorrentRegistry torrentRegistry,
IPeerRegistry peerRegistry,
ITrackerService trackerService,
EventSink eventSink) |
SeedStage(ProcessingStage<C> next,
TorrentRegistry torrentRegistry) |
Copyright © 2016–2021. All rights reserved.