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 e83523b9a06b3d38629a3827c801f798b1bf9466..28f661272353602047eb7410b2a303510bdf318e 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 |
@@ -21,7 +21,7 @@ import java.util.HashSet; |
* Tests functionality of BidirectionalStream's QUIC implementation. |
*/ |
public class BidirectionalStreamQuicTest extends CronetTestBase { |
- private CronetTestFramework mTestFramework; |
+ private ExperimentalCronetEngine mCronetEngine; |
private enum QuicBidirectionalStreams { |
ENABLED, |
DISABLED, |
@@ -52,7 +52,7 @@ public class BidirectionalStreamQuicTest extends CronetTestBase { |
CronetTestUtil.setMockCertVerifierForTesting( |
builder, QuicTestServer.createMockCertVerifier()); |
- mTestFramework = startCronetTestFrameworkWithUrlAndCronetEngineBuilder(null, builder); |
+ mCronetEngine = builder.build(); |
} |
@Override |
@@ -71,7 +71,7 @@ public class BidirectionalStreamQuicTest extends CronetTestBase { |
String quicURL = QuicTestServer.getServerURL() + path; |
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback(); |
BidirectionalStream stream = |
- mTestFramework.mCronetEngine |
+ mCronetEngine |
.newBidirectionalStreamBuilder(quicURL, callback, callback.getExecutor()) |
.setHttpMethod("GET") |
.build(); |
@@ -97,9 +97,9 @@ public class BidirectionalStreamQuicTest extends CronetTestBase { |
callback.addWriteData("1234567890".getBytes()); |
callback.addWriteData("woot!".getBytes()); |
TestRequestFinishedListener requestFinishedListener = new TestRequestFinishedListener(); |
- mTestFramework.mCronetEngine.addRequestFinishedListener(requestFinishedListener); |
+ mCronetEngine.addRequestFinishedListener(requestFinishedListener); |
BidirectionalStream stream = |
- mTestFramework.mCronetEngine |
+ mCronetEngine |
.newBidirectionalStreamBuilder(quicURL, callback, callback.getExecutor()) |
.addHeader("foo", "bar") |
.addHeader("empty", "") |
@@ -139,7 +139,7 @@ public class BidirectionalStreamQuicTest extends CronetTestBase { |
callback.addWriteData("Test String".getBytes(), false); |
callback.addWriteData("1234567890".getBytes(), false); |
callback.addWriteData("woot!".getBytes(), true); |
- BidirectionalStream stream = mTestFramework.mCronetEngine |
+ BidirectionalStream stream = mCronetEngine |
.newBidirectionalStreamBuilder( |
quicURL, callback, callback.getExecutor()) |
.delayRequestHeadersUntilFirstFlush(i == 0) |
@@ -175,7 +175,7 @@ public class BidirectionalStreamQuicTest extends CronetTestBase { |
callback.addWriteData("Test String".getBytes(), false); |
callback.addWriteData("1234567890".getBytes(), false); |
callback.addWriteData("woot!".getBytes(), true); |
- BidirectionalStream stream = mTestFramework.mCronetEngine |
+ BidirectionalStream stream = mCronetEngine |
.newBidirectionalStreamBuilder( |
quicURL, callback, callback.getExecutor()) |
.delayRequestHeadersUntilFirstFlush(i == 0) |
@@ -212,7 +212,7 @@ public class BidirectionalStreamQuicTest extends CronetTestBase { |
} |
}; |
BidirectionalStream stream = |
- mTestFramework.mCronetEngine |
+ mCronetEngine |
.newBidirectionalStreamBuilder(url, callback, callback.getExecutor()) |
.setHttpMethod("GET") |
.delayRequestHeadersUntilFirstFlush(i == 0) |
@@ -250,7 +250,7 @@ public class BidirectionalStreamQuicTest extends CronetTestBase { |
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback(); |
callback.addWriteData("Test String".getBytes(), true); |
BidirectionalStream stream = |
- mTestFramework.mCronetEngine |
+ mCronetEngine |
.newBidirectionalStreamBuilder(url, callback, callback.getExecutor()) |
.delayRequestHeadersUntilFirstFlush(i == 0) |
.addHeader("foo", "bar") |
@@ -278,7 +278,7 @@ public class BidirectionalStreamQuicTest extends CronetTestBase { |
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback(); |
BidirectionalStream stream = |
- mTestFramework.mCronetEngine |
+ mCronetEngine |
.newBidirectionalStreamBuilder(quicURL, callback, callback.getExecutor()) |
.setHttpMethod("GET") |
.build(); |
@@ -318,7 +318,7 @@ public class BidirectionalStreamQuicTest extends CronetTestBase { |
callback.addWriteData("woot!".getBytes()); |
BidirectionalStream stream = |
- mTestFramework.mCronetEngine |
+ mCronetEngine |
.newBidirectionalStreamBuilder(quicURL, callback, callback.getExecutor()) |
.addHeader("foo", "bar") |
.addHeader("empty", "") |
@@ -346,7 +346,7 @@ public class BidirectionalStreamQuicTest extends CronetTestBase { |
String quicURL = QuicTestServer.getServerURL() + path; |
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback(); |
BidirectionalStream stream = |
- mTestFramework.mCronetEngine |
+ mCronetEngine |
.newBidirectionalStreamBuilder(quicURL, callback, callback.getExecutor()) |
.setHttpMethod("GET") |
.build(); |
@@ -357,7 +357,7 @@ public class BidirectionalStreamQuicTest extends CronetTestBase { |
assertEquals("This is a simple text file served by QUIC.\n", callback.mResponseAsString); |
assertEquals("quic/1+spdy/3", callback.mResponseInfo.getNegotiatedProtocol()); |
- String serialized_data = mTestFramework.mCronetEngine.getCertVerifierData(100); |
+ String serialized_data = mCronetEngine.getCertVerifierData(100); |
assertFalse(serialized_data.isEmpty()); |
// Create a new builder and verify that the |serialized_data| is deserialized correctly. |
@@ -368,9 +368,7 @@ public class BidirectionalStreamQuicTest extends CronetTestBase { |
builder, QuicTestServer.createMockCertVerifier()); |
builder.setCertVerifierData(serialized_data); |
- CronetTestFramework testFramework = |
- startCronetTestFrameworkWithUrlAndCronetEngineBuilder(null, builder); |
- String deserialized_data = testFramework.mCronetEngine.getCertVerifierData(100); |
+ String deserialized_data = builder.build().getCertVerifierData(100); |
assertEquals(deserialized_data, serialized_data); |
} |
} |