Class DefaultStreamingDecoder
java.lang.Object
org.apache.dubbo.remoting.http12.message.DefaultStreamingDecoder
- All Implemented Interfaces:
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 -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()voiddecode(InputStream inputStream) voidvoidrequest(int numMessages) void
-
Constructor Details
-
DefaultStreamingDecoder
public DefaultStreamingDecoder()
-
-
Method Details
-
request
public void request(int numMessages) - Specified by:
requestin interfaceStreamingDecoder
-
decode
- Specified by:
decodein interfaceStreamingDecoder- Throws:
DecodeException
-
close
public void close()- Specified by:
closein interfaceStreamingDecoder
-
onStreamClosed
public void onStreamClosed()- Specified by:
onStreamClosedin interfaceStreamingDecoder
-
setFragmentListener
- Specified by:
setFragmentListenerin interfaceStreamingDecoder
-