Class Http2ServerChannelObserver
java.lang.Object
org.apache.dubbo.remoting.http12.AbstractServerHttpChannelObserver<H2StreamChannel>
org.apache.dubbo.remoting.http12.h2.Http2ServerChannelObserver
- All Implemented Interfaces:
AutoCloseable,StreamObserver<Object>,FlowControlStreamObserver<Object>,Http2CancelableStreamObserver<Object>,ServerHttpChannelObserver<H2StreamChannel>
public class Http2ServerChannelObserver
extends AbstractServerHttpChannelObserver<H2StreamChannel>
implements FlowControlStreamObserver<Object>, Http2CancelableStreamObserver<Object>
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidclose()voidSwaps to manual flow control where no message will be delivered toStreamObserver.onNext(Object)unless it isrequest()ed.booleanvoidrequest(int count) Requests the peer to producecountmore messages to be delivered to the 'inbound'StreamObserver.voidsetCancellationContext(CancellationContext cancellationContext) voidsetStreamingDecoder(StreamingDecoder streamingDecoder) Methods inherited from class org.apache.dubbo.remoting.http12.AbstractServerHttpChannelObserver
addHeadersCustomizer, addTrailersCustomizer, getHttpChannel, getResponseEncoder, onCompleted, onError, onNext, setExceptionCustomizer, setResponseEncoderMethods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.dubbo.common.stream.StreamObserver
onCompleted, onError, onNext
-
Constructor Details
-
Http2ServerChannelObserver
-
-
Method Details
-
setStreamingDecoder
-
setCancellationContext
- Specified by:
setCancellationContextin interfaceHttp2CancelableStreamObserver<Object>
-
getCancellationContext
- Specified by:
getCancellationContextin interfaceHttp2CancelableStreamObserver<Object>
-
cancel
- Specified by:
cancelin interfaceHttp2CancelableStreamObserver<Object>
-
request
public void request(int count) Description copied from interface:FlowControlStreamObserverRequests the peer to producecountmore messages to be delivered to the 'inbound'StreamObserver.This method is safe to call from multiple threads without external synchronization.
- Specified by:
requestin interfaceFlowControlStreamObserver<Object>- Parameters:
count- more messages
-
disableAutoFlowControl
public void disableAutoFlowControl()Description copied from interface:FlowControlStreamObserverSwaps to manual flow control where no message will be delivered toStreamObserver.onNext(Object)unless it isrequest()ed. Sincerequest()may not be called before the call is started, a number of initial requests may be specified.- Specified by:
disableAutoFlowControlin interfaceFlowControlStreamObserver<Object>
-
isAutoRequestN
public boolean isAutoRequestN()- Specified by:
isAutoRequestNin interfaceFlowControlStreamObserver<Object>
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceServerHttpChannelObserver<H2StreamChannel>- Overrides:
closein classAbstractServerHttpChannelObserver<H2StreamChannel>
-