Index: content/browser/streams/stream.cc |
diff --git a/content/browser/streams/stream.cc b/content/browser/streams/stream.cc |
index 38f91b82e5043179ae0a90e71636e13d45e10712..cac8ce099724cc80852bd10fae3394f4fa11d054 100644 |
--- a/content/browser/streams/stream.cc |
+++ b/content/browser/streams/stream.cc |
@@ -32,11 +32,11 @@ Stream::Stream(StreamRegistry* registry, |
write_observer_(write_observer), |
stream_handle_(NULL), |
weak_ptr_factory_(this) { |
- CreateByteStream(base::MessageLoopProxy::current(), |
- base::MessageLoopProxy::current(), |
- kDeferSizeThreshold, |
- &writer_, |
- &reader_); |
+ CreateByteStream<bool>(base::MessageLoopProxy::current(), |
+ base::MessageLoopProxy::current(), |
+ kDeferSizeThreshold, |
+ &writer_, |
+ &reader_); |
// Setup callback for writing. |
writer_->RegisterCallback(base::Bind(&Stream::OnSpaceAvailable, |
@@ -72,7 +72,8 @@ void Stream::AddData(scoped_refptr<net::IOBuffer> buffer, size_t size) { |
} |
void Stream::Finalize() { |
- writer_->Close(DOWNLOAD_INTERRUPT_REASON_NONE); |
+ // We don't use the status passing feature of ByteStream. |
+ writer_->Close(false /* status */); |
writer_.reset(NULL); |
// Continue asynchronously. |
@@ -88,14 +89,15 @@ Stream::StreamState Stream::ReadRawData(net::IOBuffer* buf, |
if (!data_.get()) { |
data_length_ = 0; |
data_bytes_read_ = 0; |
- ByteStreamReader::StreamState state = reader_->Read(&data_, &data_length_); |
+ ByteStreamReader<bool>::StreamState state = |
+ reader_->Read(&data_, &data_length_); |
switch (state) { |
- case ByteStreamReader::STREAM_HAS_DATA: |
+ case ByteStreamReader<bool>::STREAM_HAS_DATA: |
break; |
- case ByteStreamReader::STREAM_COMPLETE: |
+ case ByteStreamReader<bool>::STREAM_COMPLETE: |
registry_->UnregisterStream(url()); |
return STREAM_COMPLETE; |
- case ByteStreamReader::STREAM_EMPTY: |
+ case ByteStreamReader<bool>::STREAM_EMPTY: |
return STREAM_EMPTY; |
} |
} |