org.apache.dubbo.rpc.protocol.tri.frame

Class TriDecoder

java.lang.Object

org.apache.dubbo.rpc.protocol.tri.frame.TriDecoder

All Implemented Interfaces:

Deframer

public class TriDecoder
extends Object
implements Deframer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	TriDecoder.Listener

Constructor Summary

Constructors

Constructor and Description
TriDecoder(DeCompressor decompressor, TriDecoder.Listener listener)

Method Summary

Modifier and Type	Method and Description
void	close() Closes this deframer and frees any resources.
void	deframe(io.netty.buffer.ByteBuf data) Adds the given data to this deframer and attempts delivery to the listener.
void	request(int numMessages) Requests up to the given number of messages from the call.

Methods inherited from class java.lang.Object

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

Constructor Detail

TriDecoder

public TriDecoder(DeCompressor decompressor,
                  TriDecoder.Listener listener)

Method Detail

deframe

public void deframe(io.netty.buffer.ByteBuf data)

Description copied from interface: Deframer

Adds the given data to this deframer and attempts delivery to the listener.

Specified by:

deframe in interface Deframer

Parameters:

data - the raw data read from the remote endpoint. Must be non-null.

request

public void request(int numMessages)

Description copied from interface: Deframer

Requests up to the given number of messages from the call. No additional messages will be delivered.

If Deframer.close() has been called, this method will have no effect.

Specified by:

request in interface Deframer

Parameters:

numMessages - the requested number of messages to be delivered to the listener.

close

public void close()

Description copied from interface: Deframer

Closes this deframer and frees any resources. After this method is called, additional calls will have no effect.

Specified by:

close in interface Deframer