| 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 e6a337eb07c0a9e826adf7e4efddf2ac3f431b50..f524b998c1056cb7209b8d7c62690778f4701e4a 100644
|
| --- a/components/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java
|
| +++ b/components/cronet/android/java/src/org/chromium/net/CronetUrlRequestContext.java
|
| @@ -141,7 +141,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, callback,
|
| + executor, httpMethod, requestHeaders);
|
| + }
|
| }
|
|
|
| @Override
|
| @@ -321,7 +325,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();
|
| }
|
|
|
| @@ -329,7 +333,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();
|
| }
|
|
|
|
|