| /external/perfetto/ui/src/common/ |
| D | http_rpc_engine.ts | 41 private requestQueue = new Array<QueuedRequest>(); property in HttpRpcEngine
85 this.requestQueue.push(req);
132 if (this.pendingRequest === undefined && this.requestQueue.length > 0) {
133 this.beginFetch(this.requestQueue.shift()!);
|
| /external/pigweed/pw_web_ui/src/transport/ |
| D | serial_mock.ts | 25 private requestQueue: Array<(val: T) => unknown> = []; property in AsyncQueue
32 const callback = this.requestQueue.shift();
50 this.requestQueue.push(resolve);
|
| /external/apache-http/android/src/android/net/http/ |
| D | RequestHandle.java | 58 public RequestHandle(RequestQueue requestQueue, String url, WebAddress uri, in RequestHandle() argument
73 mRequestQueue = requestQueue; in RequestHandle()
82 public RequestHandle(RequestQueue requestQueue, String url, WebAddress uri, in RequestHandle() argument
86 this(requestQueue, url, uri, method, headers, bodyProvider, bodyLength, in RequestHandle()
|
| D | RequestQueue.java | 517 private Request removeFirst(LinkedHashMap<HttpHost, LinkedList<Request>> requestQueue) { in removeFirst() argument
519 … Iterator<Map.Entry<HttpHost, LinkedList<Request>>> iter = requestQueue.entrySet().iterator(); in removeFirst()
525 requestQueue.remove(entry.getKey()); in removeFirst()
|
| /external/volley/src/main/java/com/android/volley/ |
| D | WaitingRequestManager.java | 65 WaitingRequestManager(@NonNull RequestQueue requestQueue) { in WaitingRequestManager() argument
66 mRequestQueue = requestQueue; in WaitingRequestManager()
|
| D | Request.java | 269 public Request<?> setRequestQueue(RequestQueue requestQueue) { in setRequestQueue() argument
270 mRequestQueue = requestQueue; in setRequestQueue()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | TestThread.java | 58 private final SynchronousQueue<Request> requestQueue = new SynchronousQueue<>(); field in TestThread
191 if (!requestQueue.offer( in sendRequest()
239 Request request = requestQueue.take(); in run()
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | TestThread.java | 58 private final SynchronousQueue<Request> requestQueue = new SynchronousQueue<>(); field in TestThread
191 if (!requestQueue.offer( in sendRequest()
239 Request request = requestQueue.take(); in run()
|
| /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/ |
| D | MockWebServer.java | 112 private final BlockingQueue<RecordedRequest> requestQueue = new LinkedBlockingQueue<>(); field in MockWebServer
272 return requestQueue.take();
287 return requestQueue.poll(timeout, unit);
525 requestQueue.add(request);
869 requestQueue.add(request);
971 requestQueue.add(new RecordedRequest(requestLine, pushPromise.getHeaders(), chunkSizes, 0,
|
| /external/mockwebserver/src/main/java/com/google/mockwebserver/ |
| D | MockWebServer.java | 81 private final BlockingQueue<RecordedRequest> requestQueue field in MockWebServer
170 return requestQueue.take(); in takeRequest()
367 requestQueue.add(request); in serveConnection()
|