Package org.apache.dubbo.remoting.http12

Interface FlowControlStreamObserver<T>

All Superinterfaces:

StreamObserver<T>

All Known Implementing Classes:

Http2ServerChannelObserver

public interface FlowControlStreamObserver<T>
extends StreamObserver<T>

Method Summary

Modifier and Type	Method	Description
void	disableAutoFlowControl()	Swaps to manual flow control where no message will be delivered to StreamObserver.onNext(Object) unless it is request()ed.
boolean	isAutoRequestN()
void	request(int count)	Requests the peer to produce count more messages to be delivered to the 'inbound' StreamObserver.

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

onCompleted, onError, onNext

Method Details

request

void request(int count)

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.

Parameters:

count - more messages

isAutoRequestN

boolean isAutoRequestN()

disableAutoFlowControl

void disableAutoFlowControl()

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.