Chromecast: MessageLoopProxy cleanup --> SingleThreadTaskRunner.

chromecast/media/cma/pipeline/audio_video_pipeline_impl_unittest.cc

 // Copyright 2014 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 <vector>
 
 #include "base/basictypes.h"
 #include "base/bind.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop/message_loop.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/time/time.h"
 #include "chromecast/media/cma/backend/audio_pipeline_device.h"
 #include "chromecast/media/cma/backend/media_clock_device.h"
 #include "chromecast/media/cma/backend/media_pipeline_device.h"
 #include "chromecast/media/cma/backend/media_pipeline_device_fake.h"
 #include "chromecast/media/cma/base/buffering_controller.h"
 #include "chromecast/media/cma/base/decoder_buffer_base.h"
 #include "chromecast/media/cma/pipeline/audio_pipeline_impl.h"
 #include "chromecast/media/cma/pipeline/av_pipeline_client.h"
 #include "chromecast/media/cma/pipeline/media_pipeline_impl.h"
@@ skipping 108 matching lines @@
                  base::Unretained(media_pipeline_.get()),
                  audio_config,
                  base::Passed(&frame_provider_base),
                  next_task) :
       base::Bind(&MediaPipeline::InitializeVideo,
                  base::Unretained(media_pipeline_.get()),
                  video_config,
                  base::Passed(&frame_provider_base),
                  next_task);
 
-  base::MessageLoopProxy::current()->PostTask(FROM_HERE, task);
+  base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE, task);
 }
 
 void AudioVideoPipelineImplTest::StartPlaying(
     const base::Closure& done_cb, ::media::PipelineStatus status) {
   base::TimeDelta start_time = base::TimeDelta::FromMilliseconds(0);
 
   media_pipeline_->StartPlayingFrom(start_time);
   if (!done_cb.is_null())
     done_cb.Run();
 }
 
 void AudioVideoPipelineImplTest::OnEos() {
   task_after_eos_cb_.Run();
 }
 
 void AudioVideoPipelineImplTest::Flush(
     const base::Closure& done_cb, ::media::PipelineStatus status) {
   ::media::PipelineStatusCB next_task =
       base::Bind(&AudioVideoPipelineImplTest::Stop, base::Unretained(this),
                  done_cb);
-  base::MessageLoopProxy::current()->PostTask(
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE,
-      base::Bind(&MediaPipeline::Flush,
-                 base::Unretained(media_pipeline_.get()),
+      base::Bind(&MediaPipeline::Flush, base::Unretained(media_pipeline_.get()),
                  next_task));
 }
 
 void AudioVideoPipelineImplTest::Stop(
     const base::Closure& done_cb, ::media::PipelineStatus status) {
   media_pipeline_->Stop();
   if (!done_cb.is_null())
     done_cb.Run();
   base::MessageLoop::current()->QuitWhenIdle();
 }
@@ skipping 26 matching lines @@
       FROM_HERE,
       base::Bind(&AudioVideoPipelineImplTest::Initialize,
                  base::Unretained(this),
                  base::Closure(),
                  ::media::PIPELINE_OK, is_audio));
   message_loop->Run();
 };
 
 }  // namespace media
 }  // namespace chromecast