Package com.google.cloud.grpc

Class GcpClientCall.SimpleGcpClientCall<ReqT,RespT>

java.lang.Object

io.grpc.ClientCall<ReqT,RespT>

io.grpc.ForwardingClientCall<ReqT,RespT>

com.google.cloud.grpc.GcpClientCall.SimpleGcpClientCall<ReqT,RespT>

Enclosing class:

GcpClientCall<ReqT,RespT>

public static class GcpClientCall.SimpleGcpClientCall<ReqT,RespT>
extends io.grpc.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.

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.ForwardingClientCall

io.grpc.ForwardingClientCall.SimpleForwardingClientCall<ReqT extends Object,RespT extends Object>

Nested classes/interfaces inherited from class io.grpc.ClientCall

io.grpc.ClientCall.Listener<T extends Object>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	cancel(String message, Throwable cause)
protected io.grpc.ClientCall<ReqT,RespT>	delegate()
io.grpc.Attributes	getAttributes()
void	halfClose()
boolean	isReady()
void	request(int arg0)
void	setMessageCompression(boolean arg0)
void	start(io.grpc.ClientCall.Listener<RespT> responseListener, io.grpc.Metadata headers)
String	toString()

Methods inherited from class io.grpc.ForwardingClientCall

sendMessage

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleGcpClientCall

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

Method Details

delegate

protected io.grpc.ClientCall<ReqT,RespT> delegate()

Specified by:

delegate in class io.grpc.ForwardingClientCall<ReqT,RespT>

start

public void start(io.grpc.ClientCall.Listener<RespT> responseListener,
 io.grpc.Metadata headers)

Overrides:

start in class io.grpc.ForwardingClientCall<ReqT,RespT>

cancel

public void cancel(String message,
 Throwable cause)

request

public void request(int arg0)

Specified by:

request in class io.grpc.ClientCall<ReqT extends Object,RespT extends Object>

halfClose

public void halfClose()

Specified by:

halfClose in class io.grpc.ClientCall<ReqT extends Object,RespT extends Object>

setMessageCompression

public void setMessageCompression(boolean arg0)

Overrides:

setMessageCompression in class io.grpc.ClientCall<ReqT extends Object,RespT extends Object>

isReady

public boolean isReady()

Overrides:

isReady in class io.grpc.ClientCall<ReqT extends Object,RespT extends Object>

getAttributes

public io.grpc.Attributes getAttributes()

Overrides:

getAttributes in class io.grpc.ClientCall<ReqT extends Object,RespT extends Object>

toString

public String toString()

Overrides:

toString in class Object