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

Class DefaultStreamingDecoder

java.lang.Object

org.apache.dubbo.remoting.http12.message.DefaultStreamingDecoder

All Implemented Interfaces:

StreamingDecoder

public class DefaultStreamingDecoder
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
DefaultStreamingDecoder()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultStreamingDecoder

public DefaultStreamingDecoder()

Method Details

request

public void request(int numMessages)

Specified by:

request in interface StreamingDecoder

decode

public void decode(InputStream inputStream)
            throws DecodeException

Specified by:

decode in interface StreamingDecoder

Throws:

DecodeException

close

public void close()

Specified by:

close in interface StreamingDecoder

onStreamClosed

public void onStreamClosed()

Specified by:

onStreamClosed in interface StreamingDecoder

setFragmentListener

public void setFragmentListener(StreamingDecoder.FragmentListener listener)

Specified by:

setFragmentListener in interface StreamingDecoder