HostMessageDispatcher to parse control messages

remoting/host/client_connection.cc

 // Copyright (c) 2010 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.
 
+// TODO(hclam): Remove this header once MessageDispatcher is used.
+#include "remoting/base/multiple_array_input_stream.h"
 #include "remoting/host/client_connection.h"
 
 #include "google/protobuf/message.h"
 #include "net/base/io_buffer.h"
-#include "remoting/protocol/messages_decoder.h"
 #include "remoting/protocol/util.h"
 
 namespace remoting {
 
 // Determine how many update streams we should count to find the size of
 // average update stream.
 static const size_t kAverageUpdateStream = 10;
 
 ClientConnection::ClientConnection(MessageLoop* message_loop,
                                    EventHandler* handler)
@@ skipping 58 matching lines @@
     connection_->Close(NewRunnableMethod(this, &ClientConnection::OnClosed));
     connection_ = NULL;
   }
 }
 
 ClientConnection::ClientConnection() {}
 
 void ClientConnection::OnConnectionStateChange(
     ChromotocolConnection::State state) {
   if (state == ChromotocolConnection::CONNECTED) {
-    event_reader_.Init(
+    event_reader_.Init<ChromotingClientMessage>(
         connection_->event_channel(),
         NewCallback(this, &ClientConnection::OnMessageReceived));
     video_writer_.Init(connection_->video_channel());
   }
 
   loop_->PostTask(FROM_HERE,
       NewRunnableMethod(this, &ClientConnection::StateChangeTask, state));
 }
 
 void ClientConnection::OnMessageReceived(ChromotingClientMessage* message) {
@@ skipping 29 matching lines @@
   DCHECK_EQ(loop_, MessageLoop::current());
   DCHECK(handler_);
   handler_->HandleMessage(this, message);
 }
 
 // OnClosed() is used as a callback for ChromotocolConnection::Close().
 void ClientConnection::OnClosed() {
 }
 
 }  // namespace remoting