Remove BidirectionalStream.Builder.disableAutoFlush

components/cronet/android/test/javatests/src/org/chromium/net/BidirectionalStreamQuicTest.java

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package org.chromium.net;
 
 import android.test.suitebuilder.annotation.SmallTest;
 
 import org.chromium.base.test.util.Feature;
 import org.chromium.net.CronetTestBase.OnlyRunNativeCronet;
@@ skipping 102 matching lines @@
             String quicURL = QuicTestServer.getServerURL() + path;
             TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
             // Although we have no way to verify data sent at this point, this test
             // can make sure that onWriteCompleted is invoked appropriately.
             callback.addWriteData("Test String".getBytes(), false);
             callback.addWriteData("1234567890".getBytes(), false);
             callback.addWriteData("woot!".getBytes(), true);
             BidirectionalStream stream = new BidirectionalStream
                                                  .Builder(quicURL, callback, callback.getExecutor(),
                                                          mTestFramework.mCronetEngine)
-                                                 .disableAutoFlush(true)
                                                  .delayRequestHeadersUntilFirstFlush(i == 0)
                                                  .addHeader("foo", "bar")
                                                  .addHeader("empty", "")
                                                  .addHeader("Content-Type", "zebra")
                                                  .build();
             stream.start();
             callback.blockForDone();
             assertTrue(stream.isDone());
             assertEquals(200, callback.mResponseInfo.getHttpStatusCode());
             assertEquals(
@@ skipping 16 matching lines @@
             // can make sure that onWriteCompleted is invoked appropriately.
             callback.addWriteData("Test String".getBytes(), false);
             callback.addWriteData("1234567890".getBytes(), false);
             callback.addWriteData("woot!".getBytes(), true);
             callback.addWriteData("Test String".getBytes(), false);
             callback.addWriteData("1234567890".getBytes(), false);
             callback.addWriteData("woot!".getBytes(), true);
             BidirectionalStream stream = new BidirectionalStream
                                                  .Builder(quicURL, callback, callback.getExecutor(),
                                                          mTestFramework.mCronetEngine)
-                                                 .disableAutoFlush(true)
                                                  .delayRequestHeadersUntilFirstFlush(i == 0)
                                                  .addHeader("foo", "bar")
                                                  .addHeader("empty", "")
                                                  .addHeader("Content-Type", "zebra")
                                                  .build();
             stream.start();
             callback.blockForDone();
             assertTrue(stream.isDone());
             assertEquals(200, callback.mResponseInfo.getHttpStatusCode());
             assertEquals(
@@ skipping 17 matching lines @@
                 public void onStreamReady(BidirectionalStream stream) {
                     // This flush should send the delayed headers.
                     stream.flush();
                     super.onStreamReady(stream);
                 }
             };
             BidirectionalStream stream = new BidirectionalStream
                                                  .Builder(url, callback, callback.getExecutor(),
                                                          mTestFramework.mCronetEngine)
                                                  .setHttpMethod("GET")
-                                                 .disableAutoFlush(true)
                                                  .delayRequestHeadersUntilFirstFlush(i == 0)
                                                  .addHeader("foo", "bar")
                                                  .addHeader("empty", "")
                                                  .build();
             // Flush before stream is started should not crash.
             stream.flush();
 
             stream.start();
             callback.blockForDone();
             assertTrue(stream.isDone());
@@ skipping 17 matching lines @@
         // TODO(xunjieli): Use ParameterizedTest instead of the loop.
         for (int i = 0; i < 2; i++) {
             String path = "/simple.txt";
             String url = QuicTestServer.getServerURL() + path;
 
             TestBidirectionalStreamCallback callback = new TestBidirectionalStreamCallback();
             callback.addWriteData("Test String".getBytes(), true);
             BidirectionalStream stream = new BidirectionalStream
                                                  .Builder(url, callback, callback.getExecutor(),
                                                          mTestFramework.mCronetEngine)
-                                                 .disableAutoFlush(true)
                                                  .delayRequestHeadersUntilFirstFlush(i == 0)
                                                  .addHeader("foo", "bar")
                                                  .addHeader("empty", "")
                                                  .addHeader("Content-Type", "zebra")
                                                  .build();
             stream.start();
             callback.blockForDone();
             assertTrue(stream.isDone());
 
             assertEquals(200, callback.mResponseInfo.getHttpStatusCode());
@@ skipping 98 matching lines @@
         builder.enableQuic(true);
         builder.setMockCertVerifierForTesting(QuicTestServer.createMockCertVerifier());
         builder.setCertVerifierData(serialized_data);
 
         CronetTestFramework testFramework =
                 startCronetTestFrameworkWithUrlAndCronetEngineBuilder(null, builder);
         String deserialized_data = testFramework.mCronetEngine.getCertVerifierData(100);
         assertEquals(deserialized_data, serialized_data);
     }
 }