diff options
Diffstat (limited to 'content/browser/streams/stream.cc')
| -rw-r--r-- | content/browser/streams/stream.cc | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/content/browser/streams/stream.cc b/content/browser/streams/stream.cc index fb36ad9..3f4ae680 100644 --- a/content/browser/streams/stream.cc +++ b/content/browser/streams/stream.cc @@ -6,7 +6,8 @@ #include "base/bind.h" #include "base/location.h" -#include "base/message_loop/message_loop_proxy.h" +#include "base/single_thread_task_runner.h" +#include "base/thread_task_runner_handle.h" #include "base/values.h" #include "content/browser/streams/stream_handle_impl.h" #include "content/browser/streams/stream_read_observer.h" @@ -35,11 +36,9 @@ 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(base::ThreadTaskRunnerHandle::Get(), + base::ThreadTaskRunnerHandle::Get(), kDeferSizeThreshold, + &writer_, &reader_); // Setup callback for writing. writer_->RegisterCallback(base::Bind(&Stream::OnSpaceAvailable, @@ -122,7 +121,7 @@ void Stream::Finalize() { writer_.reset(); // Continue asynchronously. - base::MessageLoopProxy::current()->PostTask( + base::ThreadTaskRunnerHandle::Get()->PostTask( FROM_HERE, base::Bind(&Stream::OnDataAvailable, weak_ptr_factory_.GetWeakPtr())); } |