bt.net.pipeline

Class InboundMessageProcessor

java.lang.Object

bt.net.pipeline.InboundMessageProcessor

public class InboundMessageProcessor
extends Object

Inspired by Bip Buffer (https://www.codeproject.com/Articles/3479/The-Bip-Buffer-The-Circular-Buffer-with-a-Twist)

Constructor Summary

Constructors

Constructor and Description
InboundMessageProcessor(Peer peer, ByteBuffer buffer, bt.net.pipeline.MessageDeserializer deserializer, List<BufferMutator> decoders, IBufferedPieceRegistry bufferedPieceRegistry)

Method Summary

Modifier and Type	Method and Description
Message	pollMessage()
void	processInboundData()

Methods inherited from class java.lang.Object

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

Constructor Detail

InboundMessageProcessor

public InboundMessageProcessor(Peer peer,
                               ByteBuffer buffer,
                               bt.net.pipeline.MessageDeserializer deserializer,
                               List<BufferMutator> decoders,
                               IBufferedPieceRegistry bufferedPieceRegistry)

Method Detail

pollMessage

public Message pollMessage()

processInboundData

public void processInboundData()