| /external/downloader/src/main/java/com/google/android/downloader/ |
| D | CronetUrlEngine.java | 69 SettableFuture<UrlResponse> responseFuture = SettableFuture.create(); in createRequest() local
70 CronetCallback callback = new CronetCallback(responseFuture); in createRequest()
73 return new CronetUrlRequestBuilder(builder, responseFuture); in createRequest()
84 private final ListenableFuture<UrlResponse> responseFuture; field in CronetUrlEngine.CronetUrlRequest
88 responseFuture = builder.responseFuture; in CronetUrlRequest()
90 responseFuture.addListener( in CronetUrlRequest()
92 if (responseFuture.isCancelled()) { in CronetUrlRequest()
102 return responseFuture; in send()
109 private final ListenableFuture<UrlResponse> responseFuture; field in CronetUrlEngine.CronetUrlRequestBuilder
113 ListenableFuture<UrlResponse> responseFuture) { in CronetUrlRequestBuilder() argument
[all …]
|
| D | OkHttp3UrlEngine.java | 125 SettableFuture<UrlResponse> responseFuture = SettableFuture.create(); in send() local
132 responseFuture.set(new OkHttpUrlResponse(response)); in send()
134 responseFuture.setException( in send()
144 responseFuture.setException(new RequestException(exception)); in send()
147 responseFuture.addListener( in send()
149 if (responseFuture.isCancelled()) { in send()
154 return responseFuture; in send()
|
| D | OkHttp2UrlEngine.java | 125 SettableFuture<UrlResponse> responseFuture = SettableFuture.create(); in send() local
132 responseFuture.set(new OkHttpUrlResponse(response)); in send()
134 responseFuture.setException( in send()
148 responseFuture.setException(new RequestException(exception)); in send()
151 responseFuture.addListener( in send()
153 if (responseFuture.isCancelled()) { in send()
158 return responseFuture; in send()
|
| D | Downloader.java | 671 (closer, responseFuture) -> completeRequest(request, checkNotNull(responseFuture)), in runRequest()
681 DownloadRequest request, ListenableFuture<UrlResponse> responseFuture) { in completeRequest() argument
682 return ClosingFuture.from(responseFuture) in completeRequest()
|
| /external/downloader/src/test/java/com/google/android/downloader/ |
| D | MockWebServerUrlEngineTestHelper.java | 86 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_normalResponse_succeeds() local
87 UrlResponse response = responseFuture.get(); in executeRequest_normalResponse_succeeds()
130 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_responseThrottled_succeeds() local
131 UrlResponse response = responseFuture.get(); in executeRequest_responseThrottled_succeeds()
178 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_largeResponse_succeeds() local
179 UrlResponse response = responseFuture.get(); in executeRequest_largeResponse_succeeds()
216 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_closeBeforeWrite_failsAborted() local
217 UrlResponse response = responseFuture.get(); in executeRequest_closeBeforeWrite_failsAborted()
234 ListenableFuture<UrlResponse> responseFuture = request.send(); in executeRequest_serverError_failsInternalError() local
236 ExecutionException exception = assertThrows(ExecutionException.class, responseFuture::get); in executeRequest_serverError_failsInternalError()
[all …]
|
| D | CronetUrlEngineTest.java | 116 ListenableFuture<? extends UrlResponse> responseFuture = request.send(); in executeRequest_fileUrl_requestFails() local
120 ExecutionException exception = assertThrows(ExecutionException.class, responseFuture::get); in executeRequest_fileUrl_requestFails()
|
| D | PlatformUrlEngineTest.java | 119 ListenableFuture<? extends UrlResponse> responseFuture = request.send(); in executeRequest_fileUrl() local
120 UrlResponse response = responseFuture.get(); in executeRequest_fileUrl()
|
| D | DataUrlEngineTest.java | 81 ListenableFuture<? extends UrlResponse> responseFuture = request.send(); in executeRequest_invalidDataUrl() local
83 ExecutionException exception = assertThrows(ExecutionException.class, responseFuture::get); in executeRequest_invalidDataUrl()
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ClientCalls.java | 127 ListenableFuture<RespT> responseFuture = futureUnaryCall(call, req); in blockingUnaryCall() local
128 while (!responseFuture.isDone()) { in blockingUnaryCall()
139 return getUnchecked(responseFuture); in blockingUnaryCall()
188 GrpcFuture<RespT> responseFuture = new GrpcFuture<RespT>(call); in futureUnaryCall() local
189 asyncUnaryRequestCall(call, req, new UnaryStreamToFuture<RespT>(responseFuture), false); in futureUnaryCall()
190 return responseFuture; in futureUnaryCall()
450 private final GrpcFuture<RespT> responseFuture; field in ClientCalls.UnaryStreamToFuture
454 UnaryStreamToFuture(GrpcFuture<RespT> responseFuture) { in UnaryStreamToFuture() argument
455 this.responseFuture = responseFuture; in UnaryStreamToFuture()
476 responseFuture.setException( in onClose()
[all …]
|
| /external/bcc/examples/usdt_sample/usdt_sample_app1/ |
| D | main.cpp | 132 auto responseFuture = op.executeAsync(OperationRequest(inputOss.str())); in main() local
136 responseQueue.push(responseFuture); in main()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientTransportTest.java | 683 listener.responseFuture.get(10, TimeUnit.SECONDS); in waitForResponse()
693 final SettableFuture<Void> responseFuture = SettableFuture.create(); field in NettyClientTransportTest.TestClientStreamListener
711 responseFuture.setException(e); in closed()
718 responseFuture.set(null); in messagesAvailable()
|