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>

Inherited Members

io.grpc.ForwardingClientCall.delegate()

io.grpc.ForwardingClientCall.sendMessage(ReqT)

io.grpc.ForwardingClientCall.start(io.grpc.ClientCall.Listener<RespT>,io.grpc.Metadata)

io.grpc.PartialForwardingClientCall.cancel(java.lang.String,java.lang.Throwable)

io.grpc.PartialForwardingClientCall.getAttributes()

io.grpc.PartialForwardingClientCall.halfClose()

io.grpc.PartialForwardingClientCall.isReady()

io.grpc.PartialForwardingClientCall.request(int)

io.grpc.PartialForwardingClientCall.setMessageCompression(boolean)

io.grpc.PartialForwardingClientCall.toString()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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)