Fix stream errors that occur after a stream starts not propagating.

content/browser/streams/stream.cc

 // Copyright (c) 2013 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 "content/browser/streams/stream.h"
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/single_thread_task_runner.h"
 #include "base/threading/thread_task_runner_handle.h"
@@ skipping 100 matching lines @@
   memcpy(io_buffer->data(), data, size);
   AddData(io_buffer, size);
 }
 
 void Stream::Flush() {
   if (!writer_.get())
     return;
   writer_->Flush();
 }
 
-void Stream::Finalize() {
+void Stream::Finalize(int status) {
   if (!writer_.get())
     return;
 
-  writer_->Close(0);
+  writer_->Close(status);
   writer_.reset();
 
   // Continue asynchronously.
   base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE,
       base::Bind(&Stream::OnDataAvailable, weak_ptr_factory_.GetWeakPtr()));
 }
 
 Stream::StreamState Stream::ReadRawData(net::IOBuffer* buf,
                                         int buf_size,
@@ skipping 44 matching lines @@
   // Prevent deletion until this function ends.
   scoped_refptr<Stream> ref(this);
 
   CHECK(stream_handle_);
   stream_handle_ = NULL;
   registry_->UnregisterStream(url());
   if (write_observer_)
     write_observer_->OnClose(this);
 }
 
+int Stream::GetStatus() {
+  return reader_->GetStatus();
+}
+
 void Stream::OnSpaceAvailable() {
   can_add_data_ = true;
   if (write_observer_)
     write_observer_->OnSpaceAvailable(this);
 }
 
 void Stream::OnDataAvailable() {
   if (read_observer_)
     read_observer_->OnDataAvailable(this);
 }
 
 void Stream::ClearBuffer() {
   data_ = NULL;
   data_length_ = 0;
   data_bytes_read_ = 0;
 }
 
 }  // namespace content