org.apache.dubbo.rpc.protocol.tri.observer

Class ClientCallToObserverAdapter<T>

java.lang.Object

org.apache.dubbo.rpc.protocol.tri.CancelableStreamObserver<T>

org.apache.dubbo.rpc.protocol.tri.observer.ClientCallToObserverAdapter<T>

All Implemented Interfaces:

org.apache.dubbo.common.stream.StreamObserver<T>, ClientStreamObserver<T>, CallStreamObserver<T>

public class ClientCallToObserverAdapter<T>
extends CancelableStreamObserver<T>
implements ClientStreamObserver<T>

Constructor Summary

Constructors

Constructor and Description
ClientCallToObserverAdapter(ClientCall call)

Method Summary

Modifier and Type	Method and Description
void	cancel(Throwable throwable)
void	disableAutoFlowControl() Swaps to manual flow control where no message will be delivered to StreamObserver.onNext(Object) unless it is request()ed.
boolean	isAutoRequestEnabled()
void	onCompleted()
void	onError(Throwable throwable)
void	onNext(Object data)
void	request(int count) Requests the peer to produce count more messages to be delivered to the 'inbound' StreamObserver.
void	setCompression(String compression) Sets the compression algorithm to use for the call

Methods inherited from class org.apache.dubbo.rpc.protocol.tri.CancelableStreamObserver

beforeStart, getCancellationContext, setCancellationContext, startRequest

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.dubbo.rpc.protocol.tri.ClientStreamObserver

disableAutoRequest

Constructor Detail

ClientCallToObserverAdapter

public ClientCallToObserverAdapter(ClientCall call)

Method Detail

isAutoRequestEnabled

public boolean isAutoRequestEnabled()

onNext

public void onNext(Object data)

Specified by:

onNext in interface org.apache.dubbo.common.stream.StreamObserver<T>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface org.apache.dubbo.common.stream.StreamObserver<T>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface org.apache.dubbo.common.stream.StreamObserver<T>

cancel

public void cancel(Throwable throwable)

Overrides:

cancel in class CancelableStreamObserver<T>

setCompression

public void setCompression(String compression)

Description copied from interface: CallStreamObserver

Sets the compression algorithm to use for the call

For stream set compression needs to determine whether the metadata has been sent, and carry on corresponding processing

Specified by:

setCompression in interface CallStreamObserver<T>

Parameters:

compression - Compressor

request

public void request(int count)

Description copied from interface: CallStreamObserver

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 CallStreamObserver<T>

Parameters:

count - more messages

disableAutoFlowControl

public void disableAutoFlowControl()

Description copied from interface: CallStreamObserver

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 CallStreamObserver<T>