public class PieceConsumer extends Object
Constructor and Description |
---|
PieceConsumer(TorrentId torrentId,
Bitfield bitfield,
DataWorker dataWorker,
IBufferedPieceRegistry bufferedPieceRegistry,
EventSink eventSink) |
Modifier and Type | Method and Description |
---|---|
void |
consume(Piece piece,
MessageContext context) |
void |
produce(Consumer<Message> messageConsumer) |
public PieceConsumer(TorrentId torrentId, Bitfield bitfield, DataWorker dataWorker, IBufferedPieceRegistry bufferedPieceRegistry, EventSink eventSink)
public void consume(Piece piece, MessageContext context)
Copyright © 2016–2021. All rights reserved.