Index: components/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java |
diff --git a/components/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java b/components/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java |
index cac2e321c6fa6ff7cb15c15915ff212a8af7b581..cf6dd243fd6531256d742517213da4a60e958c4d 100644 |
--- a/components/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java |
+++ b/components/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java |
@@ -143,7 +143,11 @@ class CronetUrlRequestContext extends CronetEngine { |
BidirectionalStream createBidirectionalStream(String url, BidirectionalStream.Callback callback, |
Executor executor, String httpMethod, List<Map.Entry<String, String>> requestHeaders, |
@BidirectionalStream.Builder.StreamPriority int priority) { |
- throw new UnsupportedOperationException(); |
+ synchronized (mLock) { |
+ checkHaveAdapter(); |
+ return new CronetBidirectionalStream( |
+ this, url, priority, callback, executor, httpMethod, requestHeaders); |
+ } |
} |
@Override |
@@ -343,7 +347,7 @@ class CronetUrlRequestContext extends CronetEngine { |
* Mark request as started to prevent shutdown when there are active |
* requests. |
*/ |
- void onRequestStarted(UrlRequest urlRequest) { |
+ void onRequestStarted() { |
mActiveRequestCount.incrementAndGet(); |
} |
@@ -351,7 +355,7 @@ class CronetUrlRequestContext extends CronetEngine { |
* Mark request as finished to allow shutdown when there are no active |
* requests. |
*/ |
- void onRequestDestroyed(UrlRequest urlRequest) { |
+ void onRequestDestroyed() { |
mActiveRequestCount.decrementAndGet(); |
} |