Class ManagedChannelImpl.ConfigSelectingClientCall<ReqT,RespT>

java.lang.Object

io.grpc.ClientCall<ReqT,RespT>

io.grpc.PartialForwardingClientCall<ReqT,RespT>

io.grpc.ForwardingClientCall<ReqT,RespT>

io.grpc.internal.ManagedChannelImpl.ConfigSelectingClientCall<ReqT,RespT>

Enclosing class:

ManagedChannelImpl

static final class ManagedChannelImpl.ConfigSelectingClientCall<ReqT,RespT>
extends ForwardingClientCall<ReqT,RespT>

A client call for a given channel that applies a given config selector when it starts.

Nested Class Summary

Nested classes/interfaces inherited from class ForwardingClientCall

ForwardingClientCall.SimpleForwardingClientCall<ReqT,RespT>

Nested classes/interfaces inherited from class ClientCall

ClientCall.Listener<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final Executor	callExecutor
private CallOptions	callOptions
private final Channel	channel
private final InternalConfigSelector	configSelector
private final Context	context
private ClientCall<ReqT,RespT>	delegate
private final MethodDescriptor<ReqT,RespT>	method

Constructor Summary

Constructors

Constructor	Description
ConfigSelectingClientCall(InternalConfigSelector configSelector, Channel channel, Executor channelExecutor, MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)

Method Summary

Modifier and Type	Method	Description
void	cancel(String message, Throwable cause)	Prevent any further processing for this ClientCall.
protected ClientCall<ReqT,RespT>	delegate()	Returns the delegated ClientCall.
private void	executeCloseObserverInContext(ClientCall.Listener<RespT> observer, Status status)
void	start(ClientCall.Listener<RespT> observer, Metadata headers)	Start a call, using responseListener for processing response messages.

Methods inherited from class ForwardingClientCall

sendMessage

Methods inherited from class PartialForwardingClientCall

getAttributes, halfClose, isReady, request, setMessageCompression, toString

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

configSelector

private final InternalConfigSelector configSelector

channel

private final Channel channel

callExecutor

private final Executor callExecutor

method

private final MethodDescriptor<ReqT,RespT> method

context

private final Context context

callOptions

private CallOptions callOptions

delegate

private ClientCall<ReqT,RespT> delegate

Constructor Details

ConfigSelectingClientCall

ConfigSelectingClientCall(InternalConfigSelector configSelector,
 Channel channel,
 Executor channelExecutor,
 MethodDescriptor<ReqT,RespT> method,
 CallOptions callOptions)

Method Details

delegate

protected ClientCall<ReqT,RespT> delegate()

Description copied from class: ForwardingClientCall

Returns the delegated ClientCall.

Specified by:

delegate in class ForwardingClientCall<ReqT,RespT>

start

public void start(ClientCall.Listener<RespT> observer,
 Metadata headers)

Description copied from class: ClientCall

Start a call, using responseListener for processing response messages.

It must be called prior to any other method on this class, except for ClientCall.cancel(String, Throwable) which may be called at any time.

Since Metadata is not thread-safe, the caller must not access (read or write) headers after this point.

Overrides:

start in class ForwardingClientCall<ReqT,RespT>

Parameters:

observer - receives response messages

headers - which can contain extra call metadata, e.g. authentication credentials.

executeCloseObserverInContext

private void executeCloseObserverInContext(ClientCall.Listener<RespT> observer,
 Status status)

cancel

public void cancel(@Nullable
 String message,
 @Nullable
 Throwable cause)

Description copied from class: ClientCall

Prevent any further processing for this ClientCall. No further messages may be sent or will be received. The server is informed of cancellations, but may not stop processing the call. Cancellation is permitted even if previously ClientCall.halfClose()d. Cancelling an already cancel()ed ClientCall has no effect.

No other methods on this class can be called after this method has been called.

It is recommended that at least one of the arguments to be non-null, to provide useful debug information. Both argument being null may log warnings and result in suboptimal performance. Also note that the provided information will not be sent to the server.

Overrides:

cancel in class PartialForwardingClientCall<ReqT,RespT>

Parameters:

message - if not null, will appear as the description of the CANCELLED status

cause - if not null, will appear as the cause of the CANCELLED status