[Stream] Notify ReadObserver of Stream abortion

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 59 matching lines @@
 }
 
 void Stream::Abort() {
   // Clear all buffer. It's safe to clear reader_ here since the same thread
   // is used for both input and output operation.
   writer_.reset();
   reader_.reset();
   ClearBuffer();
   can_add_data_ = false;
   registry_->UnregisterStream(url());
+  // Notify the observer that something happens. Read will return
+  // STREAM_ABORTED.
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE,
+      base::Bind(&Stream::OnDataAvailable, weak_ptr_factory_.GetWeakPtr()));
 }
 
 void Stream::AddData(scoped_refptr<net::IOBuffer> buffer, size_t size) {
   if (!writer_.get())
     return;
 
   size_t current_buffered_bytes = writer_->GetTotalBufferedBytes();
   if (!registry_->UpdateMemoryUsage(url(), current_buffered_bytes, size)) {
     Abort();
     return;
@@ skipping 103 matching lines @@
     read_observer_->OnDataAvailable(this);
 }
 
 void Stream::ClearBuffer() {
   data_ = NULL;
   data_length_ = 0;
   data_bytes_read_ = 0;
 }
 
 }  // namespace content