Searched defs:responseFuture (Results 1 – 11 of 11) sorted by relevance
86 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_normalResponse_succeeds() local130 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_responseThrottled_succeeds() local178 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_largeResponse_succeeds() local216 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_closeBeforeWrite_failsAborted() local234 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_serverError_failsInternalError() local255 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_networkError_failsInternalError() local271 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_writeError_failsInternalError() local298 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_requestCanceled_requestNeverSent() local312 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_invalidUrl_failsInvalidArgument() local
81 ListenableFuture<? extends UrlResponse> responseFuture = request.send(); in executeRequest_invalidDataUrl() local
116 ListenableFuture<? extends UrlResponse> responseFuture = request.send(); in executeRequest_fileUrl_requestFails() local
119 ListenableFuture<? extends UrlResponse> responseFuture = request.send(); in executeRequest_fileUrl() local
69 SettableFuture<UrlResponse> responseFuture = SettableFuture.create(); in createRequest() local84 private final ListenableFuture<UrlResponse> responseFuture; field in CronetUrlEngine.CronetUrlRequest109 private final ListenableFuture<UrlResponse> responseFuture; field in CronetUrlEngine.CronetUrlRequestBuilder113 ListenableFuture<UrlResponse> responseFuture) { in CronetUrlRequestBuilder()181 private final SettableFuture<UrlResponse> responseFuture; field in CronetUrlEngine.CronetCallback188 CronetCallback(SettableFuture<UrlResponse> responseFuture) { in CronetCallback()
125 SettableFuture<UrlResponse> responseFuture = SettableFuture.create(); in send() local
681 DownloadRequest request, ListenableFuture<UrlResponse> responseFuture) { in completeRequest()
127 ListenableFuture<RespT> responseFuture = futureUnaryCall(call, req); in blockingUnaryCall() local188 GrpcFuture<RespT> responseFuture = new GrpcFuture<RespT>(call); in futureUnaryCall() local450 private final GrpcFuture<RespT> responseFuture; field in ClientCalls.UnaryStreamToFuture454 UnaryStreamToFuture(GrpcFuture<RespT> responseFuture) { in UnaryStreamToFuture()
132 auto responseFuture = op.executeAsync(OperationRequest(inputOss.str())); in main() local
693 final SettableFuture<Void> responseFuture = SettableFuture.create(); field in NettyClientTransportTest.TestClientStreamListener