Add Flush() method to ByteStream.

content/browser/byte_stream.h

 // Copyright (c) 2012 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.
 
 #ifndef CONTENT_BROWSER_BYTE_STREAM_H_
 #define CONTENT_BROWSER_BYTE_STREAM_H_
 
 #include <deque>
 #include <set>
 #include <utility>
@@ skipping 116 matching lines @@
   static const int kFractionBufferBeforeSending;
 
   virtual ~ByteStreamWriter() = 0;
 
   // Always adds the data passed into the ByteStream.  Returns true
   // if more data may be added without exceeding the class limit
   // on data.  Takes ownership of |buffer|.
   virtual bool Write(scoped_refptr<net::IOBuffer> buffer,
                      size_t byte_count) = 0;
 
+  // Flushes contents buffered in this writer to the corresponding reader
+  // regardless if buffer filling rate is greater than
+  // kFractionBufferBeforeSending or not. Does nothing if there's no contents
+  // buffered.
+  virtual void Flush() = 0;
+
   // Signal that all data that is going to be sent, has been sent,
   // and provide a status.  |DOWNLOAD_INTERRUPT_REASON_NONE| should be
   // passed for successful completion.
   virtual void Close(DownloadInterruptReason status) = 0;
 
   // Register a callback to be called when the stream transitions from
   // full to having space available.  The callback will always be
   // called on the task runner associated with the ByteStreamWriter.
   // This callback will only be called if a call to Write has previously
   // returned false (i.e. the ByteStream has been filled).
@@ skipping 40 matching lines @@
 CONTENT_EXPORT void CreateByteStream(
     scoped_refptr<base::SequencedTaskRunner> input_task_runner,
     scoped_refptr<base::SequencedTaskRunner> output_task_runner,
     size_t buffer_size,
     scoped_ptr<ByteStreamWriter>* input,
     scoped_ptr<ByteStreamReader>* output);
 
 }  // namespace content
 
 #endif  // CONTENT_BROWSER_BYTE_STREAM_H_