[Cronet] Don't send endOfStream if there is pending data to flush on iOS.

components/cronet/ios/cronet_bidirectional_stream.cc

 // 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.
 
 #include "components/cronet/ios/cronet_bidirectional_stream.h"
 
 #include <memory>
 #include <string>
 #include <vector>
 
@@ skipping 202 matching lines @@
   for (const scoped_refptr<net::IOBuffer>& buffer :
        sending_write_data_->buffers()) {
     delegate_->OnDataSent(buffer->data());
   }
   sending_write_data_->Clear();
   // Send data flushed while other data was sending.
   if (!flushing_write_data_->Empty()) {
     SendFlushingWriteData();
     return;
   }
-  if (write_end_of_stream_ && pending_write_data_->Empty())
+  if (write_end_of_stream_ && pending_write_data_->Empty()) {
     write_state_ = WRITING_DONE;
-  MaybeOnSucceded();
+    MaybeOnSucceded();
+  }
 }
 
 void CronetBidirectionalStream::OnTrailersReceived(
     const net::SpdyHeaderBlock& response_trailers) {
   DCHECK(environment_->IsOnNetworkThread());
   delegate_->OnTrailersReceived(response_trailers);
 }
 
 void CronetBidirectionalStream::OnFailed(int error) {
   DCHECK(environment_->IsOnNetworkThread());
@@ skipping 90 matching lines @@
 }
 
 void CronetBidirectionalStream::SendFlushingWriteData() {
   // If previous send is not done, or there is nothing to flush, then exit.
   if (write_state_ == WRITING || flushing_write_data_->Empty())
     return;
   DCHECK(sending_write_data_->Empty());
   write_state_ = WRITING;
   flushing_write_data_->MoveTo(sending_write_data_.get());
   bidi_stream_->SendvData(sending_write_data_->buffers(),
-                          sending_write_data_->lengths(), write_end_of_stream_);
+                          sending_write_data_->lengths(),
+                          write_end_of_stream_ && pending_write_data_->Empty());
 }
 
 void CronetBidirectionalStream::CancelOnNetworkThread() {
   DCHECK(environment_->IsOnNetworkThread());
   if (!bidi_stream_)
     return;
   read_state_ = write_state_ = CANCELED;
   bidi_stream_.reset();
   delegate_->OnCanceled();
 }
 
 void CronetBidirectionalStream::DestroyOnNetworkThread() {
   DCHECK(environment_->IsOnNetworkThread());
   delete this;
 }
 
 void CronetBidirectionalStream::MaybeOnSucceded() {
   DCHECK(environment_->IsOnNetworkThread());
   if (read_state_ == READING_DONE && write_state_ == WRITING_DONE) {
     read_state_ = write_state_ = SUCCESS;
     bidi_stream_.reset();
     delegate_->OnSucceeded();
   }
 }
 
 }  // namespace cronet