Package org.apache.dubbo.remoting.http12.message

Class LengthFieldStreamingDecoder

java.lang.Object

org.apache.dubbo.remoting.http12.message.LengthFieldStreamingDecoder

All Implemented Interfaces:

StreamingDecoder

public class LengthFieldStreamingDecoder
extends Object
implements StreamingDecoder

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.dubbo.remoting.http12.message.StreamingDecoder

StreamingDecoder.DefaultFragmentListener, StreamingDecoder.FragmentListener, StreamingDecoder.NoopFragmentListener

Constructor Summary

Constructors

Constructor	Description
LengthFieldStreamingDecoder()
LengthFieldStreamingDecoder(int lengthFieldLength)
LengthFieldStreamingDecoder(int lengthFieldOffset, int lengthFieldLength)

Method Summary

Modifier and Type	Method	Description
final void	close()
final void	decode(InputStream inputStream)
void	invokeListener(InputStream inputStream)
final void	onStreamClosed()
final void	request(int numMessages)
final void	setFragmentListener(StreamingDecoder.FragmentListener listener)

Methods inherited from class java.lang.Object

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

Constructor Details

LengthFieldStreamingDecoder

public LengthFieldStreamingDecoder()

LengthFieldStreamingDecoder

public LengthFieldStreamingDecoder(int lengthFieldLength)

LengthFieldStreamingDecoder

public LengthFieldStreamingDecoder(int lengthFieldOffset,
 int lengthFieldLength)

Method Details

decode

public final void decode(InputStream inputStream)
                  throws DecodeException

Specified by:

decode in interface StreamingDecoder

Throws:

DecodeException

request

public final void request(int numMessages)

Specified by:

request in interface StreamingDecoder

close

public final void close()

Specified by:

close in interface StreamingDecoder

onStreamClosed

public final void onStreamClosed()

Specified by:

onStreamClosed in interface StreamingDecoder

setFragmentListener

public final void setFragmentListener(StreamingDecoder.FragmentListener listener)

Specified by:

setFragmentListener in interface StreamingDecoder

invokeListener

public void invokeListener(InputStream inputStream)