Add AllReadDataConsumed and AllWriteDataConsumed methods to SocketDataProvider

net/socket/sequenced_socket_data_unittest.cc

 // Copyright 2015 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.
 
 #include <string>
 
 #include "base/macros.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/run_loop.h"
@@ skipping 224 matching lines @@
           OnHostResolutionCallback(),
           TransportSocketParams::COMBINE_CONNECT_AND_WRITE_DEFAULT)),
       socket_pool_(10, 10, &socket_factory_),
       expect_eof_(true) {
 }
 
 SequencedSocketDataTest::~SequencedSocketDataTest() {
   // Make sure no unexpected pending tasks will cause a failure.
   base::RunLoop().RunUntilIdle();
   if (expect_eof_) {
-    EXPECT_EQ(expect_eof_, data_->at_read_eof());
-    EXPECT_EQ(expect_eof_, data_->at_write_eof());
+    EXPECT_EQ(expect_eof_, data_->AllReadDataConsumed());
+    EXPECT_EQ(expect_eof_, data_->AllWriteDataConsumed());
   }
 }
 
 void SequencedSocketDataTest::Initialize(MockRead* reads,
                                          size_t reads_count,
                                          MockWrite* writes,
                                          size_t writes_count) {
   data_.reset(
       new SequencedSocketData(reads, reads_count, writes, writes_count));
   data_->set_connect_data(connect_data_);
@@ skipping 809 matching lines @@
 
   ASSERT_EQ(ERR_IO_PENDING,
             sock_->Read(helper.read_buf().get(), kLen1, helper.callback()));
 
   base::MessageLoop::current()->RunUntilIdle();
 }
 
 }  // namespace
 
 }  // namespace net