diff options
author | Android Build Coastguard Worker <android-build-coastguard-worker@google.com> | 2021-07-15 02:07:05 +0000 |
---|---|---|
committer | Android Build Coastguard Worker <android-build-coastguard-worker@google.com> | 2021-07-15 02:07:05 +0000 |
commit | 095f7608fd5a89b2ac7d81e76dc893f804b1c2cb (patch) | |
tree | bafe6d115be2559d39c73bfd437bb9d14e3d596a /src/main/java/com/android/volley/RequestQueue.java | |
parent | 5c532a6de0f207c1d42c3ef5578b82f46c8641d1 (diff) | |
parent | 5731f9f9aea90e074693bdfdeb3b58fd218e374d (diff) | |
download | volley-095f7608fd5a89b2ac7d81e76dc893f804b1c2cb.tar.gz |
Snap for 7550930 from 5731f9f9aea90e074693bdfdeb3b58fd218e374d to mainline-resolv-releaseandroid-mainline-12.0.0_r94android-mainline-12.0.0_r80android-mainline-12.0.0_r65android-mainline-12.0.0_r52android-mainline-12.0.0_r35android-mainline-12.0.0_r16android-mainline-12.0.0_r124android-mainline-12.0.0_r108android12-mainline-resolv-release
Change-Id: Iffa1cbc90243f1888b6044b9b46bec76b0e8a5f0
Diffstat (limited to 'src/main/java/com/android/volley/RequestQueue.java')
-rw-r--r-- | src/main/java/com/android/volley/RequestQueue.java | 20 |
1 files changed, 16 insertions, 4 deletions
diff --git a/src/main/java/com/android/volley/RequestQueue.java b/src/main/java/com/android/volley/RequestQueue.java index c127c7f..6db0b1c 100644 --- a/src/main/java/com/android/volley/RequestQueue.java +++ b/src/main/java/com/android/volley/RequestQueue.java @@ -263,13 +263,17 @@ public class RequestQueue { request.addMarker("add-to-queue"); sendRequestEvent(request, RequestEvent.REQUEST_QUEUED); + beginRequest(request); + return request; + } + + <T> void beginRequest(Request<T> request) { // If the request is uncacheable, skip the cache queue and go straight to the network. if (!request.shouldCache()) { - mNetworkQueue.add(request); - return request; + sendRequestOverNetwork(request); + } else { + mCacheQueue.add(request); } - mCacheQueue.add(request); - return request; } /** @@ -327,4 +331,12 @@ public class RequestQueue { mFinishedListeners.remove(listener); } } + + public ResponseDelivery getResponseDelivery() { + return mDelivery; + } + + <T> void sendRequestOverNetwork(Request<T> request) { + mNetworkQueue.add(request); + } } |