public class TorrentProcessorFactory extends Object implements ProcessorFactory
Constructor and Description |
---|
TorrentProcessorFactory(TorrentRegistry torrentRegistry,
DataWorker dataWorker,
IBufferedPieceRegistry bufferedPieceRegistry,
ITrackerService trackerService,
ExecutorService executor,
IPeerRegistry peerRegistry,
IConnectionSource connectionSource,
IPeerConnectionPool connectionPool,
IMessageDispatcher messageDispatcher,
Set<Object> messagingAgents,
IMetadataService metadataService,
EventSource eventSource,
EventSink eventSink,
Config config) |
Modifier and Type | Method and Description |
---|---|
protected ChainProcessor<MagnetContext> |
createMagnetProcessor() |
protected ChainProcessor<TorrentContext> |
createTorrentProcessor() |
<C extends ProcessingContext> |
processor(Class<C> contextType)
Build a processor for a given context type.
|
@Inject public TorrentProcessorFactory(TorrentRegistry torrentRegistry, DataWorker dataWorker, IBufferedPieceRegistry bufferedPieceRegistry, ITrackerService trackerService, ExecutorService executor, IPeerRegistry peerRegistry, IConnectionSource connectionSource, IPeerConnectionPool connectionPool, IMessageDispatcher messageDispatcher, Set<Object> messagingAgents, IMetadataService metadataService, EventSource eventSource, EventSink eventSink, Config config)
protected ChainProcessor<TorrentContext> createTorrentProcessor()
protected ChainProcessor<MagnetContext> createMagnetProcessor()
public <C extends ProcessingContext> Processor<C> processor(Class<C> contextType)
ProcessorFactory
processor
in interface ProcessorFactory
contextType
- Processing context typeCopyright © 2016–2021. All rights reserved.