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 da864df6ec05231bf33a3c033fcb3f1985b2a2f7..c2cebf1fca743cdc845f24cb9f8dbf6d75e3f11e 100644 |
--- a/components/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java |
+++ b/components/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java |
@@ -160,7 +160,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, mUrlRequestContextAdapter, url, priority, |
+ callback, executor, httpMethod, requestHeaders); |
+ } |
} |
@Override |
@@ -360,7 +364,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(); |
} |
@@ -368,7 +372,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(); |
} |