Searched defs:retFuture (Results 1 – 3 of 3) sorted by relevance
40 private final ApiFuture<?> retFuture; field in AccumulatingBatchReceiver42 public AccumulatingBatchReceiver(ApiFuture<?> retFuture) { in AccumulatingBatchReceiver()
221 final SettableApiFuture<Void> retFuture = SettableApiFuture.create(); in pushCurrentBatch() local
69 auto retFuture = rrefsReadyFuture->thenAsync( in processMessage() local91 auto retFuture = processRpcWithErrors(*rpc, messageType, streams); in processMessage() local