Class GcpClientCall.SimpleGcpClientCall<ReqT,RespT> (1.11.0) 

public static class GcpClientCall.SimpleGcpClientCall<ReqT,RespT> extends ForwardingClientCall<ReqT,RespT>

A simple wrapper of ClientCall.

It defines the callback function to manage the number of active streams of a ChannelRef everytime a call is started/closed.

Inheritance

java.lang.Object > io.grpc.ClientCall > io.grpc.PartialForwardingClientCall > io.grpc.ForwardingClientCall > GcpClientCall.SimpleGcpClientCall<ReqT,RespT>

Type Parameters
Name Description
ReqT
RespT

Constructors

SimpleGcpClientCall(GcpManagedChannel delegateChannel, GcpManagedChannel.ChannelRef channelRef, MethodDescriptor<ReqT,RespT> methodDescriptor, CallOptions callOptions)

protected SimpleGcpClientCall(GcpManagedChannel delegateChannel, GcpManagedChannel.ChannelRef channelRef, MethodDescriptor<ReqT,RespT> methodDescriptor, CallOptions callOptions)
Parameters
Name Description
delegateChannel GcpManagedChannel
channelRef GcpManagedChannel.ChannelRef
methodDescriptor io.grpc.MethodDescriptor<ReqT,RespT>
callOptions io.grpc.CallOptions

Methods

cancel(String message, Throwable cause)

public void cancel(String message, Throwable cause)
Parameters
Name Description
message String
cause Throwable
Overrides
io.grpc.PartialForwardingClientCall.cancel(java.lang.String,java.lang.Throwable)

delegate()

protected ClientCall<ReqT,RespT> delegate()
Returns
Type Description
io.grpc.ClientCall<ReqT,RespT>
Overrides
io.grpc.ForwardingClientCall.delegate()

start(ClientCall.Listener<RespT> responseListener, Metadata headers)

public void start(ClientCall.Listener<RespT> responseListener, Metadata headers)
Parameters
Name Description
responseListener io.grpc.ClientCall.Listener<RespT>
headers io.grpc.Metadata
Overrides
io.grpc.ForwardingClientCall.start(io.grpc.ClientCall.Listener<RespT>,io.grpc.Metadata)