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

Class ServerCallToObserverAdapter<T>

java.lang.Object

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

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

All Implemented Interfaces:

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

public class ServerCallToObserverAdapter<T>
extends CancelableStreamObserver<T>
implements ServerStreamObserver<T>

Field Summary

Fields

Modifier and Type	Field and Description
CancellationContext	cancellationContext

Constructor Summary

Constructors

Constructor and Description
ServerCallToObserverAdapter(AbstractServerCall call, CancellationContext cancellationContext)

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	isAutoRequestN()
boolean	isTerminated()
boolean	isTimeout(long cost)
void	onCompleted()
void	onCompleted(TriRpcStatus status)
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
void	setResponseAttachments(Map<String,Object> attachments)

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.ServerStreamObserver

disableAutoInboundFlowControl

Field Detail

cancellationContext

public final CancellationContext cancellationContext

Constructor Detail

ServerCallToObserverAdapter

public ServerCallToObserverAdapter(AbstractServerCall call,
                                   CancellationContext cancellationContext)

Method Detail

isAutoRequestN

public boolean isAutoRequestN()

isTerminated

public boolean isTerminated()

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(TriRpcStatus status)

onCompleted

public void onCompleted()

Specified by:

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

setResponseAttachments

public void setResponseAttachments(Map<String,Object> attachments)

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

cancel

public void cancel(Throwable throwable)

Overrides:

cancel in class CancelableStreamObserver<T>

isTimeout

public boolean isTimeout(long cost)

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>

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