public class DefaultChannelPipeline extends Object implements ChannelPipeline
Constructor and Description |
---|
DefaultChannelPipeline(Peer peer,
MessageHandler<Message> protocol,
BorrowedBuffer<ByteBuffer> inboundBuffer,
BorrowedBuffer<ByteBuffer> outboundBuffer,
List<BufferMutator> decoders,
List<BufferMutator> encoders,
IBufferedPieceRegistry bufferedPieceRegistry) |
Modifier and Type | Method and Description |
---|---|
ChannelHandlerContext |
bindHandler(ChannelHandler handler)
Attach channel handler to this pipeline
|
Message |
decode() |
boolean |
encode(Message message) |
public DefaultChannelPipeline(Peer peer, MessageHandler<Message> protocol, BorrowedBuffer<ByteBuffer> inboundBuffer, BorrowedBuffer<ByteBuffer> outboundBuffer, List<BufferMutator> decoders, List<BufferMutator> encoders, IBufferedPieceRegistry bufferedPieceRegistry)
public Message decode()
decode
in interface ChannelPipeline
public boolean encode(Message message)
encode
in interface ChannelPipeline
message
- Outgoing message to encodepublic ChannelHandlerContext bindHandler(ChannelHandler handler)
ChannelPipeline
bindHandler
in interface ChannelPipeline
Copyright © 2016–2021. All rights reserved.