Searched refs:responseFuture (Results 1 – 3 of 3) sorted by relevance
127 ListenableFuture<RespT> responseFuture = futureUnaryCall(call, req); in blockingUnaryCall() local128 while (!responseFuture.isDone()) { in blockingUnaryCall()139 return getUnchecked(responseFuture); in blockingUnaryCall()188 GrpcFuture<RespT> responseFuture = new GrpcFuture<RespT>(call); in futureUnaryCall() local189 asyncUnaryRequestCall(call, req, new UnaryStreamToFuture<RespT>(responseFuture), false); in futureUnaryCall()190 return responseFuture; in futureUnaryCall()450 private final GrpcFuture<RespT> responseFuture; field in ClientCalls.UnaryStreamToFuture454 UnaryStreamToFuture(GrpcFuture<RespT> responseFuture) { in UnaryStreamToFuture() argument455 this.responseFuture = responseFuture; in UnaryStreamToFuture()476 responseFuture.setException( in onClose()[all …]
132 auto responseFuture = op.executeAsync(OperationRequest(inputOss.str())); in main() local136 responseQueue.push(responseFuture); in main()
672 listener.responseFuture.get(10, TimeUnit.SECONDS); in waitForResponse()682 final SettableFuture<Void> responseFuture = SettableFuture.create(); field in NettyClientTransportTest.TestClientStreamListener700 responseFuture.setException(e); in closed()707 responseFuture.set(null); in messagesAvailable()