| Index: components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamQuicTest.java
|
| diff --git a/components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamQuicTest.java b/components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamQuicTest.java
|
| index b3dbbc4514faf0343ec14d92f717f4f078252868..93ef668af8f1c68a12835f647c6b745be3e6f2ee 100644
|
| --- a/components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamQuicTest.java
|
| +++ b/components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamQuicTest.java
|
| @@ -10,7 +10,6 @@ import android.test.suitebuilder.annotation.SmallTest;
|
|
|
| import org.chromium.base.test.util.Feature;
|
| import org.chromium.net.CronetTestBase.OnlyRunNativeCronet;
|
| -import org.chromium.net.MetricsTestUtil.TestExecutor;
|
| import org.chromium.net.MetricsTestUtil.TestRequestFinishedListener;
|
| import org.json.JSONObject;
|
|
|
| @@ -94,9 +93,7 @@ public class BidirectionalStreamQuicTest extends CronetTestBase {
|
| callback.addWriteData("Test String".getBytes());
|
| callback.addWriteData("1234567890".getBytes());
|
| callback.addWriteData("woot!".getBytes());
|
| - TestExecutor testExecutor = new TestExecutor();
|
| - TestRequestFinishedListener requestFinishedListener =
|
| - new TestRequestFinishedListener(testExecutor);
|
| + TestRequestFinishedListener requestFinishedListener = new TestRequestFinishedListener();
|
| mTestFramework.mCronetEngine.addRequestFinishedListener(requestFinishedListener);
|
| BidirectionalStream stream = new BidirectionalStream
|
| .Builder(quicURL, callback, callback.getExecutor(),
|
| @@ -109,8 +106,8 @@ public class BidirectionalStreamQuicTest extends CronetTestBase {
|
| .build();
|
| stream.start();
|
| callback.blockForDone();
|
| - testExecutor.runAllTasks();
|
| assertTrue(stream.isDone());
|
| + requestFinishedListener.blockUntilDone();
|
| RequestFinishedInfo finishedInfo = requestFinishedListener.getRequestInfo();
|
| assertNotNull("RequestFinishedInfo.Listener must be called", finishedInfo);
|
| assertEquals(quicURL, finishedInfo.getUrl());
|
|
|