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 227bd41f9d8c4c389f99e220bfc1e45b54d049fc..df43dc12c60764b0ab4b60b884490012434b8c9e 100644 |
--- a/components/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java |
+++ b/components/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java |
@@ -120,7 +120,11 @@ class CronetUrlRequestContext extends CronetEngine { |
@Override |
BidirectionalStream createBidirectionalStream(String url, BidirectionalStream.Callback callback, |
Executor executor, String httpMethod, List<Map.Entry<String, String>> requestHeaders) { |
- throw new UnsupportedOperationException(); |
+ synchronized (mLock) { |
+ checkHaveAdapter(); |
+ return new CronetBidirectionalStream(this, mUrlRequestContextAdapter, url, callback, |
+ executor, httpMethod, requestHeaders); |
+ } |
} |
@Override |
@@ -300,7 +304,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(); |
} |
@@ -308,7 +312,7 @@ class CronetUrlRequestContext extends CronetEngine { |
* Mark request as completed to allow shutdown when there are no active |
* requests. |
*/ |
- void onRequestDestroyed(UrlRequest urlRequest) { |
+ void onRequestDestroyed() { |
mActiveRequestCount.decrementAndGet(); |
} |