类的使用
com.baidu.brpc.client.RpcFuture

使用RpcFuture的程序包

程序包	说明
com.baidu.brpc
com.baidu.brpc.client
com.baidu.brpc.interceptor
com.baidu.brpc.protocol
com.baidu.brpc.server

com.baidu.brpc中RpcFuture的使用

返回RpcFuture的com.baidu.brpc中的方法

限定符和类型	方法和说明
RpcFuture	ChannelInfo.getRpcFuture(long correlationId)
RpcFuture	ChannelInfo.removeRpcFuture(long correlationId)

参数类型为RpcFuture的com.baidu.brpc中的方法

限定符和类型	方法和说明
long	ChannelInfo.addRpcFuture(RpcFuture future)

com.baidu.brpc.client中RpcFuture的使用

返回RpcFuture的com.baidu.brpc.client中的方法

限定符和类型	方法和说明
static RpcFuture	RpcFuture.createRpcFuture(Request request, RpcClient rpcClient)
RpcFuture	FastFutureStore.get(long id) Retrieve object identified by id
RpcFuture	FastFutureStore.getAndRemove(long id) Retrieve and remove object identified by id

参数类型为RpcFuture的com.baidu.brpc.client中的方法

限定符和类型	方法和说明
void	FastFutureStore.StoreWalker.actionAfterDelete(RpcFuture fut) Action performed after a deletion of the element.
long	FastFutureStore.put(RpcFuture fut) Add an object.
<T> AsyncAwareFuture<T>	RpcClient.sendRequestCore(Request request, io.netty.buffer.ByteBuf byteBuf, RpcFuture rpcFuture)
boolean	FastFutureStore.StoreWalker.visitElement(RpcFuture fut) Action on a none-null element.

com.baidu.brpc.interceptor中RpcFuture的使用

参数类型为RpcFuture的com.baidu.brpc.interceptor中的方法

限定符和类型	方法和说明
protected void	LoadBalanceInterceptor.rpcCore(Request request, io.netty.buffer.ByteBuf byteBuf, RpcFuture rpcFuture, Response response)

com.baidu.brpc.protocol中RpcFuture的使用

返回RpcFuture的com.baidu.brpc.protocol中的方法

限定符和类型	方法和说明
RpcFuture	Response.getRpcFuture()

参数类型为RpcFuture的com.baidu.brpc.protocol中的方法

限定符和类型	方法和说明
void	Response.setRpcFuture(RpcFuture rpcFuture)

com.baidu.brpc.server中RpcFuture的使用

com.baidu.brpc.server中RpcFuture的子类

限定符和类型	类和说明
class	ServerPushRpcFuture

返回RpcFuture的com.baidu.brpc.server中的方法

限定符和类型	方法和说明
RpcFuture	PushServerRpcFutureManager.getRpcFuture(Long logId)
RpcFuture	PushServerRpcFutureManager.removeRpcFuture(Long logId)

参数类型为RpcFuture的com.baidu.brpc.server中的方法

限定符和类型	方法和说明
long	PushServerRpcFutureManager.putRpcFuture(RpcFuture future)