Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(184)

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamTest.java

Issue 2339223002: Cronet API Refactoring (Closed)
Patch Set: Javadoc + rebase Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« components/cronet/android/java/src/org/chromium/net/impl/UrlRequestBuilderImpl.java ('K') | « components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamQuicTest.java ('k') | components/cronet/android/test/javatests/src/org/chromium/net/ChromiumUrlRequestTest.java » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamTest.java
diff --git a/components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamTest.java b/components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamTest.java
index 63ea7fc69a05de048c068237a8a1ac1cf6ed2b2d..b4d1805cdca552da91969234049c09318af04161 100644
--- a/components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamTest.java
+++ b/components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamTest.java
@@ -9,7 +9,6 @@ import android.test.suitebuilder.annotation.SmallTest;
import org.chromium.base.test.util.DisabledTest;
import org.chromium.base.test.util.Feature;
-import org.chromium.net.CronetTestBase.OnlyRunNativeCronet;
import org.chromium.net.TestBidirectionalStreamCallback.FailureType;
import org.chromium.net.TestBidirectionalStreamCallback.ResponseStep;
import org.chromium.net.impl.CronetBidirectionalStream;
@@ -34,8 +33,10 @@ public class BidirectionalStreamTest extends CronetTestBase {
super.setUp();
// Load library first to create MockCertVerifier.
System.loadLibrary("cronet_tests");
- CronetEngine.Builder builder = new CronetEngine.Builder(getContext());
- builder.setMockCertVerifierForTesting(QuicTestServer.createMockCertVerifier());
+ ExperimentalCronetEngine.Builder builder =
+ new ExperimentalCronetEngine.Builder(getContext());
+ CronetTestUtil.setMockCertVerifierForTesting(
+ builder, QuicTestServer.createMockCertVerifier());
mTestFramework = startCronetTestFrameworkWithUrlAndCronetEngineBuilder(null, builder);
assertTrue(Http2TestServer.startHttp2TestServer(
@@ -89,11 +90,11 @@ public class BidirectionalStreamTest extends CronetTestBase {
String url = Http2TestServer.getEchoMethodUrl();
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
// Create stream.
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .setHttpMethod("GET")
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .setHttpMethod("GET")
+ .build();
stream.start();
callback.blockForDone();
assertTrue(stream.isDone());
@@ -108,40 +109,34 @@ public class BidirectionalStreamTest extends CronetTestBase {
@SmallTest
@Feature({"Cronet"})
+ @OnlyRunNativeCronet
public void testBuilderChecks() throws Exception {
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
try {
- new BidirectionalStream.Builder(
- null, callback, callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ null, callback, callback.getExecutor());
fail("URL not null-checked");
} catch (NullPointerException e) {
assertEquals("URL is required.", e.getMessage());
}
try {
- new BidirectionalStream.Builder(Http2TestServer.getServerUrl(), null,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getServerUrl(), null, callback.getExecutor());
fail("Callback not null-checked");
} catch (NullPointerException e) {
assertEquals("Callback is required.", e.getMessage());
}
try {
- new BidirectionalStream.Builder(
- Http2TestServer.getServerUrl(), callback, null, mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getServerUrl(), callback, null);
fail("Executor not null-checked");
} catch (NullPointerException e) {
assertEquals("Executor is required.", e.getMessage());
}
- try {
- new BidirectionalStream.Builder(
- Http2TestServer.getServerUrl(), callback, callback.getExecutor(), null);
- fail("CronetEngine not null-checked");
- } catch (NullPointerException e) {
- assertEquals("CronetEngine is required.", e.getMessage());
- }
// Verify successful creation doesn't throw.
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getServerUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getServerUrl(), callback, callback.getExecutor());
try {
builder.addHeader(null, "value");
fail("Header name is not null-checked");
@@ -169,10 +164,10 @@ public class BidirectionalStreamTest extends CronetTestBase {
String url = "http://example.com";
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
// Create stream.
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .build();
stream.start();
callback.blockForDone();
assertTrue(stream.isDone());
@@ -197,11 +192,11 @@ public class BidirectionalStreamTest extends CronetTestBase {
String url = Http2TestServer.getEchoMethodUrl();
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
// Create stream.
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .setHttpMethod("HEAD")
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .setHttpMethod("HEAD")
+ .build();
stream.start();
callback.blockForDone();
assertTrue(stream.isDone());
@@ -223,13 +218,13 @@ public class BidirectionalStreamTest extends CronetTestBase {
callback.addWriteData("1234567890".getBytes());
callback.addWriteData("woot!".getBytes());
// Create stream.
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .addHeader("foo", "bar")
- .addHeader("empty", "")
- .addHeader("Content-Type", "zebra")
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .addHeader("foo", "bar")
+ .addHeader("empty", "")
+ .addHeader("Content-Type", "zebra")
+ .build();
stream.start();
callback.blockForDone();
assertTrue(stream.isDone());
@@ -250,13 +245,13 @@ public class BidirectionalStreamTest extends CronetTestBase {
callback.addWriteData("Test String".getBytes(), false);
callback.addWriteData("1234567890".getBytes(), false);
callback.addWriteData("woot!".getBytes(), true);
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .addHeader("foo", "bar")
- .addHeader("empty", "")
- .addHeader("Content-Type", "zebra")
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .addHeader("foo", "bar")
+ .addHeader("empty", "")
+ .addHeader("Content-Type", "zebra")
+ .build();
// Flush before stream is started should not crash.
stream.flush();
@@ -328,13 +323,13 @@ public class BidirectionalStreamTest extends CronetTestBase {
callback.addWriteData("4".getBytes(), false);
callback.addWriteData("5".getBytes(), true);
callback.addWriteData("6".getBytes(), false);
- CronetBidirectionalStream stream = (CronetBidirectionalStream) new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .addHeader("foo", "bar")
- .addHeader("empty", "")
- .addHeader("Content-Type", "zebra")
- .build();
+ CronetBidirectionalStream stream =
+ (CronetBidirectionalStream) mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .addHeader("foo", "bar")
+ .addHeader("empty", "")
+ .addHeader("Content-Type", "zebra")
+ .build();
callback.setAutoAdvance(false);
stream.start();
callback.waitForNextWriteStep(); // onStreamReady
@@ -387,14 +382,14 @@ public class BidirectionalStreamTest extends CronetTestBase {
}
}
};
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .setHttpMethod("GET")
- .delayRequestHeadersUntilFirstFlush(i == 0)
- .addHeader("foo", "bar")
- .addHeader("empty", "")
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .setHttpMethod("GET")
+ .delayRequestHeadersUntilFirstFlush(i == 0)
+ .addHeader("foo", "bar")
+ .addHeader("empty", "")
+ .build();
// Flush before stream is started should not crash.
stream.flush();
@@ -422,14 +417,14 @@ public class BidirectionalStreamTest extends CronetTestBase {
String url = Http2TestServer.getEchoStreamUrl();
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
callback.addWriteData("Test String".getBytes(), true);
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .delayRequestHeadersUntilFirstFlush(i == 0)
- .addHeader("foo", "bar")
- .addHeader("empty", "")
- .addHeader("Content-Type", "zebra")
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .delayRequestHeadersUntilFirstFlush(i == 0)
+ .addHeader("foo", "bar")
+ .addHeader("empty", "")
+ .addHeader("Content-Type", "zebra")
+ .build();
stream.start();
callback.blockForDone();
assertTrue(stream.isDone());
@@ -457,14 +452,14 @@ public class BidirectionalStreamTest extends CronetTestBase {
callback.addWriteData("Test String".getBytes(), false);
callback.addWriteData("1234567890".getBytes(), false);
callback.addWriteData("woot!".getBytes(), true);
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .delayRequestHeadersUntilFirstFlush(i == 0)
- .addHeader("foo", "bar")
- .addHeader("empty", "")
- .addHeader("Content-Type", "zebra")
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .delayRequestHeadersUntilFirstFlush(i == 0)
+ .addHeader("foo", "bar")
+ .addHeader("empty", "")
+ .addHeader("Content-Type", "zebra")
+ .build();
stream.start();
callback.blockForDone();
assertTrue(stream.isDone());
@@ -499,13 +494,13 @@ public class BidirectionalStreamTest extends CronetTestBase {
callback.addWriteData("Test String".getBytes());
callback.addWriteData("1234567890".getBytes());
callback.addWriteData("woot!".getBytes());
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .addHeader("foo", "bar")
- .addHeader("empty", "")
- .addHeader("Content-Type", "zebra")
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .addHeader("foo", "bar")
+ .addHeader("empty", "")
+ .addHeader("Content-Type", "zebra")
+ .build();
stream.start();
callback.blockForDone();
assertTrue(stream.isDone());
@@ -539,13 +534,13 @@ public class BidirectionalStreamTest extends CronetTestBase {
callback.addWriteData("Test String".getBytes(), false);
callback.addWriteData("1234567890".getBytes(), false);
callback.addWriteData("woot!".getBytes(), true);
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .addHeader("foo", "bar")
- .addHeader("empty", "")
- .addHeader("Content-Type", "zebra")
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .addHeader("foo", "bar")
+ .addHeader("empty", "")
+ .addHeader("Content-Type", "zebra")
+ .build();
stream.start();
callback.blockForDone();
assertTrue(stream.isDone());
@@ -566,8 +561,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
callback.addWriteData("Put This Data!".getBytes());
String methodName = "PUT";
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getServerUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getServerUrl(), callback, callback.getExecutor());
builder.setHttpMethod(methodName);
builder.build().start();
callback.blockForDone();
@@ -582,8 +577,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
public void testBadMethod() throws Exception {
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getServerUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getServerUrl(), callback, callback.getExecutor());
try {
builder.setHttpMethod("bad:method!");
builder.build().start();
@@ -599,8 +594,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
public void testBadHeaderName() throws Exception {
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getServerUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getServerUrl(), callback, callback.getExecutor());
try {
builder.addHeader("goodheader1", "headervalue");
builder.addHeader("header:name", "headervalue");
@@ -618,8 +613,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
public void testBadHeaderValue() throws Exception {
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getServerUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getServerUrl(), callback, callback.getExecutor());
try {
builder.addHeader("headername", "bad header\r\nvalue");
builder.build().start();
@@ -637,8 +632,9 @@ public class BidirectionalStreamTest extends CronetTestBase {
String headerName = "header-name";
String headerValue = "header-value";
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoHeaderUrl(headerName),
- callback, callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoHeaderUrl(headerName), callback,
+ callback.getExecutor());
builder.addHeader(headerName, headerValue);
builder.setHttpMethod("GET");
builder.build().start();
@@ -656,8 +652,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
String headerValue1 = "header-value1";
String headerValue2 = "header-value2";
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoAllHeadersUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoAllHeadersUrl(), callback, callback.getExecutor());
builder.addHeader(headerName, headerValue1);
builder.addHeader(headerName, headerValue2);
builder.setHttpMethod("GET");
@@ -683,8 +679,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
String headerName = "header-name";
String headerValue = "header-value";
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoTrailersUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoTrailersUrl(), callback, callback.getExecutor());
builder.addHeader(headerName, headerValue);
builder.setHttpMethod("GET");
builder.build().start();
@@ -703,8 +699,9 @@ public class BidirectionalStreamTest extends CronetTestBase {
String userAgentValue = "User-Agent-Value";
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoHeaderUrl(userAgentName),
- callback, callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoHeaderUrl(userAgentName), callback,
+ callback.getExecutor());
builder.setHttpMethod("GET");
builder.addHeader(userAgentName, userAgentValue);
builder.build().start();
@@ -719,15 +716,15 @@ public class BidirectionalStreamTest extends CronetTestBase {
public void testCustomCronetEngineUserAgent() throws Exception {
String userAgentName = "User-Agent";
String userAgentValue = "User-Agent-Value";
- CronetEngine engine =
- new CronetEngine.Builder(getContext())
- .setMockCertVerifierForTesting(QuicTestServer.createMockCertVerifier())
- .setUserAgent(userAgentValue)
- .build();
+ ExperimentalCronetEngine.Builder engineBuilder =
+ new ExperimentalCronetEngine.Builder(getContext());
+ engineBuilder.setUserAgent(userAgentValue);
+ CronetTestUtil.setMockCertVerifierForTesting(
+ engineBuilder, QuicTestServer.createMockCertVerifier());
+ ExperimentalCronetEngine engine = engineBuilder.build();
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
- BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoHeaderUrl(userAgentName),
- callback, callback.getExecutor(), engine);
+ BidirectionalStream.Builder builder = engine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoHeaderUrl(userAgentName), callback, callback.getExecutor());
builder.setHttpMethod("GET");
builder.build().start();
callback.blockForDone();
@@ -742,8 +739,9 @@ public class BidirectionalStreamTest extends CronetTestBase {
String userAgentName = "User-Agent";
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoHeaderUrl(userAgentName),
- callback, callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoHeaderUrl(userAgentName), callback,
+ callback.getExecutor());
builder.setHttpMethod("GET");
builder.build().start();
callback.blockForDone();
@@ -765,12 +763,12 @@ public class BidirectionalStreamTest extends CronetTestBase {
stringData.append(writeData);
}
// Create stream.
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .addHeader("foo", "Value with Spaces")
- .addHeader("Content-Type", "zebra")
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .addHeader("foo", "Value with Spaces")
+ .addHeader("Content-Type", "zebra")
+ .build();
stream.start();
callback.blockForDone();
assertTrue(stream.isDone());
@@ -790,10 +788,10 @@ public class BidirectionalStreamTest extends CronetTestBase {
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
callback.addWriteData(new byte[0]);
// Create stream.
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .build();
stream.start();
callback.blockForDone();
assertTrue(stream.isDone());
@@ -820,10 +818,10 @@ public class BidirectionalStreamTest extends CronetTestBase {
callback.addWriteData("1".getBytes());
callback.addWriteData("2".getBytes());
// Create stream.
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .build();
stream.start();
callback.blockForDone();
assertTrue(stream.isDone());
@@ -855,10 +853,10 @@ public class BidirectionalStreamTest extends CronetTestBase {
callback.addWriteData("1".getBytes());
callback.addWriteData("2".getBytes());
// Create stream.
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .build();
stream.start();
callback.blockForDone();
assertTrue(stream.isDone());
@@ -886,10 +884,10 @@ public class BidirectionalStreamTest extends CronetTestBase {
callback.addWriteData("1".getBytes());
callback.addWriteData("2".getBytes());
// Create stream.
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .build();
stream.start();
callback.waitForNextWriteStep();
callback.waitForNextReadStep();
@@ -915,10 +913,10 @@ public class BidirectionalStreamTest extends CronetTestBase {
stringData.append(writeData);
}
// Create stream.
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .build();
stream.start();
// Write first.
callback.waitForNextWriteStep(); // onStreamReady
@@ -960,10 +958,10 @@ public class BidirectionalStreamTest extends CronetTestBase {
stringData.append(writeData);
}
// Create stream.
- BidirectionalStream stream = new BidirectionalStream
- .Builder(url, callback, callback.getExecutor(),
- mTestFramework.mCronetEngine)
- .build();
+ BidirectionalStream stream =
+ mTestFramework.mCronetEngine
+ .newBidirectionalStreamBuilder(url, callback, callback.getExecutor())
+ .build();
stream.start();
callback.waitForNextWriteStep();
callback.waitForNextReadStep();
@@ -1000,8 +998,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
callback.setAutoAdvance(false);
// Since the method is "GET", the expected response body is also "GET".
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoMethodUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoMethodUrl(), callback, callback.getExecutor());
BidirectionalStream stream = builder.setHttpMethod("GET").build();
stream.start();
callback.waitForNextReadStep();
@@ -1093,8 +1091,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
callback.setAutoAdvance(false);
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoMethodUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoMethodUrl(), callback, callback.getExecutor());
BidirectionalStream stream = builder.setHttpMethod("GET").build();
stream.start();
callback.waitForNextReadStep();
@@ -1137,8 +1135,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
callback.setFailure(failureType, failureStep);
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoMethodUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoMethodUrl(), callback, callback.getExecutor());
BidirectionalStream stream = builder.setHttpMethod("GET").build();
stream.start();
callback.blockForDone();
@@ -1188,8 +1186,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
callback.setFailure(FailureType.THROW_SYNC, ResponseStep.ON_SUCCEEDED);
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoMethodUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoMethodUrl(), callback, callback.getExecutor());
BidirectionalStream stream = builder.setHttpMethod("GET").build();
stream.start();
callback.blockForDone();
@@ -1209,8 +1207,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
callback.setAutoAdvance(false);
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoMethodUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoMethodUrl(), callback, callback.getExecutor());
CronetBidirectionalStream stream =
(CronetBidirectionalStream) builder.setHttpMethod("GET").build();
stream.start();
@@ -1279,8 +1277,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
// if there are active streams.
callback.setAutoAdvance(false);
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoMethodUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoMethodUrl(), callback, callback.getExecutor());
CronetBidirectionalStream stream =
(CronetBidirectionalStream) builder.setHttpMethod("GET").build();
stream.start();
@@ -1324,8 +1322,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
// Test that CronetEngine can be shut down after stream reports a failure.
TestBidirectionalStreamCallback callback = new ShutdownTestBidirectionalStreamCallback();
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoMethodUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoMethodUrl(), callback, callback.getExecutor());
CronetBidirectionalStream stream =
(CronetBidirectionalStream) builder.setHttpMethod("GET").build();
stream.start();
@@ -1342,8 +1340,8 @@ public class BidirectionalStreamTest extends CronetTestBase {
// Test that CronetEngine can be shut down after stream is canceled.
TestBidirectionalStreamCallback callback = new ShutdownTestBidirectionalStreamCallback();
BidirectionalStream.Builder builder =
- new BidirectionalStream.Builder(Http2TestServer.getEchoMethodUrl(), callback,
- callback.getExecutor(), mTestFramework.mCronetEngine);
+ mTestFramework.mCronetEngine.newBidirectionalStreamBuilder(
+ Http2TestServer.getEchoMethodUrl(), callback, callback.getExecutor());
CronetBidirectionalStream stream =
(CronetBidirectionalStream) builder.setHttpMethod("GET").build();
« components/cronet/android/java/src/org/chromium/net/impl/UrlRequestBuilderImpl.java ('K') | « components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamQuicTest.java ('k') | components/cronet/android/test/javatests/src/org/chromium/net/ChromiumUrlRequestTest.java » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698