com.baidu.brpc.client

Class RpcFuture<T>

java.lang.Object

com.baidu.brpc.client.RpcFuture<T>

All Implemented Interfaces:

AsyncAwareFuture<T>, Future<T>

Direct Known Subclasses:

ServerPushRpcFuture

public class RpcFuture<T>
extends Object
implements AsyncAwareFuture<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected RpcCallback<T>	callback
protected ChannelInfo	channelInfo
protected ChannelType	channelType
protected long	correlationId
protected long	endTime
protected List<Interceptor>	interceptors
protected boolean	isDone
protected CountDownLatch	latch
protected Request	request
protected Response	response
protected RpcMethodInfo	rpcMethodInfo
protected long	startTime
protected io.netty.util.Timeout	timeout

Constructor Summary

Constructors

Constructor and Description
RpcFuture()
RpcFuture(long correlationId)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
static RpcFuture	createRpcFuture(Request request)
T	get()
T	get(long timeout, TimeUnit unit)
void	handleConnection(Response response)
void	handleResponse(Response response)
void	init(io.netty.util.Timeout timeout, RpcMethodInfo rpcMethodInfo, RpcCallback<T> callback, ChannelInfo channelInfo)
boolean	isAsync()
boolean	isCancelled()
boolean	isDone()
protected void	setRpcContext()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

latch

protected CountDownLatch latch

timeout

protected io.netty.util.Timeout timeout

request

protected Request request

callback

protected RpcCallback<T> callback

channelInfo

protected ChannelInfo channelInfo

channelType

protected ChannelType channelType

rpcMethodInfo

protected RpcMethodInfo rpcMethodInfo

response

protected Response response

isDone

protected boolean isDone

startTime

protected long startTime

endTime

protected long endTime

correlationId

protected volatile long correlationId

interceptors

protected List<Interceptor> interceptors

Constructor Detail

RpcFuture

public RpcFuture()

RpcFuture

public RpcFuture(long correlationId)

Method Detail

createRpcFuture

public static RpcFuture createRpcFuture(Request request)

init

public void init(io.netty.util.Timeout timeout,
                 RpcMethodInfo rpcMethodInfo,
                 RpcCallback<T> callback,
                 ChannelInfo channelInfo)

handleConnection

public void handleConnection(Response response)

handleResponse

public void handleResponse(Response response)

isAsync

public boolean isAsync()

Specified by:

isAsync in interface AsyncAwareFuture<T>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<T>

get

public T get()
      throws InterruptedException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

get

public T get(long timeout,
             TimeUnit unit)

Specified by:

get in interface Future<T>

toString

public String toString()

Overrides:

toString in class Object

setRpcContext

protected void setRpcContext()