Package org.apache.dubbo.remoting.http12.h2

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

Constructor	Description
Http2ServerChannelObserver(H2StreamChannel h2StreamChannel)

Method Summary

Modifier and Type	Method	Description
void	cancel(Throwable throwable)
void	close()
void	disableAutoFlowControl()	Swaps to manual flow control where no message will be delivered to StreamObserver.onNext(Object) unless it is request()ed.
CancellationContext	getCancellationContext()
boolean	isAutoRequestN()
void	request(int count)	Requests the peer to produce count more messages to be delivered to the 'inbound' StreamObserver.
void	setCancellationContext(CancellationContext cancellationContext)
void	setStreamingDecoder(StreamingDecoder streamingDecoder)

Methods inherited from class org.apache.dubbo.remoting.http12.AbstractServerHttpChannelObserver

addHeadersCustomizer, addTrailersCustomizer, getHttpChannel, getResponseEncoder, onCompleted, onError, onNext, setExceptionCustomizer, setResponseEncoder

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.dubbo.common.stream.StreamObserver

onCompleted, onError, onNext

Constructor Details

Http2ServerChannelObserver

public Http2ServerChannelObserver(H2StreamChannel h2StreamChannel)

Method Details

setStreamingDecoder

public void setStreamingDecoder(StreamingDecoder streamingDecoder)

setCancellationContext

public void setCancellationContext(CancellationContext cancellationContext)

Specified by:

setCancellationContext in interface Http2CancelableStreamObserver<Object>

getCancellationContext

public CancellationContext getCancellationContext()

Specified by:

getCancellationContext in interface Http2CancelableStreamObserver<Object>

cancel

public void cancel(Throwable throwable)

Specified by:

cancel in interface Http2CancelableStreamObserver<Object>

request

public void request(int count)

Description copied from interface: FlowControlStreamObserver

Requests the peer to produce count more messages to be delivered to the 'inbound' StreamObserver.

This method is safe to call from multiple threads without external synchronization.

Specified by:

request in interface FlowControlStreamObserver<Object>

Parameters:

count - more messages

disableAutoFlowControl

public void disableAutoFlowControl()

Description copied from interface: FlowControlStreamObserver

Swaps to manual flow control where no message will be delivered to StreamObserver.onNext(Object) unless it is request()ed. Since request() may not be called before the call is started, a number of initial requests may be specified.

Specified by:

disableAutoFlowControl in interface FlowControlStreamObserver<Object>

isAutoRequestN

public boolean isAutoRequestN()

Specified by:

isAutoRequestN in interface FlowControlStreamObserver<Object>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ServerHttpChannelObserver<H2StreamChannel>

Overrides:

close in class AbstractServerHttpChannelObserver<H2StreamChannel>