HomeSort by relevance Sort by last modified time
    Searched refs:responseFuture (Results 1 - 3 of 3) sorted by null

  /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
ClientCalls.java 127 ListenableFuture<RespT> responseFuture = futureUnaryCall(call, req);
128 while (!responseFuture.isDone()) {
139 return getUnchecked(responseFuture);
188 GrpcFuture<RespT> responseFuture = new GrpcFuture<RespT>(call);
189 asyncUnaryRequestCall(call, req, new UnaryStreamToFuture<RespT>(responseFuture), false);
190 return responseFuture;
450 private final GrpcFuture<RespT> responseFuture;
454 UnaryStreamToFuture(GrpcFuture<RespT> responseFuture) {
455 this.responseFuture = responseFuture;
    [all...]
  /external/bcc/examples/usdt_sample/usdt_sample_app1/
main.cpp 132 auto responseFuture = op.executeAsync(OperationRequest(inputOss.str()));
136 responseQueue.push(responseFuture);
  /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
NettyClientTransportTest.java 672 listener.responseFuture.get(10, TimeUnit.SECONDS);
682 final SettableFuture<Void> responseFuture = SettableFuture.create();
700 responseFuture.setException(e);
707 responseFuture.set(null);

Completed in 80 milliseconds