corresponding change in CaptureVideoDecoder and RTCVideoDecoder due to pull model used in medi...

content/renderer/media/capture_video_decoder_unittest.cc

 // Copyright (c) 2011 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 "base/bind.h"
 #include "content/renderer/media/capture_video_decoder.h"
 #include "content/renderer/media/video_capture_impl.h"
 #include "content/renderer/media/video_capture_impl_manager.h"
 #include "media/base/filters.h"
 #include "media/base/limits.h"
@@ skipping 134 matching lines @@
     decoder_->Seek(base::TimeDelta(),
                    media::NewExpectedStatusCB(media::PIPELINE_OK));
     message_loop_->RunAllPending();
   }
 
   void Play() {
     decoder_->Play(media::NewExpectedClosure());
     message_loop_->RunAllPending();
   }
 
+  void Flush() {
+    // Issue a read.
+    EXPECT_CALL(*this, FrameReady(_));
+    decoder_->Read(read_cb_);
+
+    decoder_->Pause(media::NewExpectedClosure());
+    decoder_->Flush(media::NewExpectedClosure());
+    message_loop_->RunAllPending();
+  }
+
   void Stop() {
     EXPECT_CALL(*vc_impl_, StopCapture(capture_client()))
         .Times(1)
         .WillOnce(CaptureStopped(capture_client(), vc_impl_.get()));
     EXPECT_CALL(*vc_manager_, RemoveDevice(_, _))
         .WillOnce(Return());
     decoder_->Stop(media::NewExpectedClosure());
     message_loop_->RunAllPending();
   }
 
@@ skipping 26 matching lines @@
   EXPECT_EQ(kHeight, decoder_->natural_size().height());
 
   Stop();
 }
 
 TEST_F(CaptureVideoDecoderTest, Play) {
   // Test basic initialize, play, and teardown sequence.
   Initialize();
   Start();
   Play();
+  Flush();
   Stop();
 }
 
 TEST_F(CaptureVideoDecoderTest, OnDeviceInfoReceived) {
   // Test that natural size gets updated as device information is sent.
   Initialize();
   Start();
 
   gfx::Size expected_size(kWidth * 2, kHeight * 2);
 
   media::VideoCaptureParams params;
   params.width = expected_size.width();
   params.height = expected_size.height();
   params.frame_per_second = kFPS;
   params.session_id = kVideoStreamId;
 
   EXPECT_CALL(host_, SetNaturalVideoSize(expected_size));
   decoder_->OnDeviceInfoReceived(vc_impl_.get(), params);
   message_loop_->RunAllPending();
 
   EXPECT_EQ(expected_size.width(), decoder_->natural_size().width());
   EXPECT_EQ(expected_size.height(), decoder_->natural_size().height());
 
   Stop();
 }