bt.torrent.messaging

Class PeerRequestConsumer

java.lang.Object

bt.torrent.messaging.PeerRequestConsumer

public class PeerRequestConsumer
extends Object

Consumes block requests, received from the remote peer, and produces blocks.

Since:

1.0

Constructor Summary

Constructors

Constructor and Description
PeerRequestConsumer(TorrentId torrentId, DataWorker dataWorker)

Method Summary

Modifier and Type	Method and Description
void	consume(Request request, MessageContext context)
void	produce(Consumer<Message> messageConsumer, MessageContext context)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PeerRequestConsumer

public PeerRequestConsumer(TorrentId torrentId,
                           DataWorker dataWorker)

Method Detail

consume

public void consume(Request request,
                    MessageContext context)

produce

public void produce(Consumer<Message> messageConsumer,
                    MessageContext context)