Add InputEventTimestampSource interface.

remoting/protocol/webrtc_connection_to_client.cc

Index: remoting/protocol/webrtc_connection_to_client.cc
diff --git a/remoting/protocol/webrtc_connection_to_client.cc b/remoting/protocol/webrtc_connection_to_client.cc
index a1df3511fd36107269be16ba5f745283b5ffaf3d..60f02823a1acd68fa951e6a9366e9c5f30b5fcc5 100644
--- a/remoting/protocol/webrtc_connection_to_client.cc
+++ b/remoting/protocol/webrtc_connection_to_client.cc
@@ -83,6 +83,8 @@ std::unique_ptr<VideoStream> WebrtcConnectionToClient::StartVideoStream(
   std::unique_ptr<WebrtcVideoStream> stream(new WebrtcVideoStream());
   stream->Start(std::move(desktop_capturer), transport_.get(),
                 video_encode_task_runner_);
+  stream->SetEventTimestampsSource(
+      event_dispatcher_->event_timestamps_source());
   return std::move(stream);
 }
 
@@ -181,9 +183,6 @@ void WebrtcConnectionToClient::OnWebrtcTransportIncomingDataChannel(
   DCHECK(thread_checker_.CalledOnValidThread());
   if (name == event_dispatcher_->channel_name() &&
       !event_dispatcher_->is_connected()) {
-    event_dispatcher_->set_on_input_event_callback(
-        base::Bind(&WebrtcConnectionToClient::OnInputEventReceived,
-                   base::Unretained(this)));
     event_dispatcher_->Init(std::move(pipe), this);
   }
 }
@@ -218,10 +217,5 @@ void WebrtcConnectionToClient::OnChannelClosed(
   Disconnect(INCOMPATIBLE_PROTOCOL);
 }
 
-void WebrtcConnectionToClient::OnInputEventReceived(int64_t timestamp) {
-  DCHECK(thread_checker_.CalledOnValidThread());
-  event_handler_->OnInputEventReceived(timestamp);
-}
-
 }  // namespace protocol
 }  // namespace remoting