| Index: content/browser/streams/stream_handle_impl.cc
|
| diff --git a/content/browser/streams/stream_handle_impl.cc b/content/browser/streams/stream_handle_impl.cc
|
| index ba4dee2a4900945af800f2429e0f8edf24d270b2..5bc2acbf4fa8f95cebc6fb765084a460f1098382 100644
|
| --- a/content/browser/streams/stream_handle_impl.cc
|
| +++ b/content/browser/streams/stream_handle_impl.cc
|
| @@ -6,7 +6,7 @@
|
|
|
| #include "base/bind.h"
|
| #include "base/location.h"
|
| -#include "base/thread_task_runner_handle.h"
|
| +#include "base/message_loop/message_loop_proxy.h"
|
| #include "content/browser/streams/stream.h"
|
|
|
| namespace content {
|
| @@ -23,12 +23,11 @@ void RunCloseListeners(const std::vector<base::Closure>& close_listeners) {
|
| StreamHandleImpl::StreamHandleImpl(const base::WeakPtr<Stream>& stream)
|
| : stream_(stream),
|
| url_(stream->url()),
|
| - stream_task_runner_(base::ThreadTaskRunnerHandle::Get().get()) {
|
| -}
|
| + stream_message_loop_(base::MessageLoopProxy::current().get()) {}
|
|
|
| StreamHandleImpl::~StreamHandleImpl() {
|
| - stream_task_runner_->PostTaskAndReply(
|
| - FROM_HERE, base::Bind(&Stream::CloseHandle, stream_),
|
| + stream_message_loop_->PostTaskAndReply(FROM_HERE,
|
| + base::Bind(&Stream::CloseHandle, stream_),
|
| base::Bind(&RunCloseListeners, close_listeners_));
|
| }
|
|
|
|
|