Add support for dynamic channels in WebrtcTransport.

remoting/protocol/channel_dispatcher_base.cc

 // Copyright (c) 2012 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 "remoting/protocol/channel_dispatcher_base.h"
 
 #include <utility>
 
 #include "base/bind.h"
 #include "remoting/base/compound_buffer.h"
@@ skipping 13 matching lines @@
 
 void ChannelDispatcherBase::Init(MessageChannelFactory* channel_factory,
                                  EventHandler* event_handler) {
   channel_factory_ = channel_factory;
   event_handler_ = event_handler;
 
   channel_factory_->CreateChannel(channel_name_, base::Bind(
       &ChannelDispatcherBase::OnChannelReady, base::Unretained(this)));
 }
 
+void ChannelDispatcherBase::Init(std::unique_ptr<MessagePipe> message_pipe,
+                                 EventHandler* event_handler) {
+  event_handler_ = event_handler;
+  OnChannelReady(std::move(message_pipe));
+}
+
 void ChannelDispatcherBase::OnChannelReady(
     std::unique_ptr<MessagePipe> message_pipe) {
   channel_factory_ = nullptr;
   message_pipe_ = std::move(message_pipe);
-  message_pipe_->StartReceiving(base::Bind(
-      &ChannelDispatcherBase::OnIncomingMessage, base::Unretained(this)));
+  message_pipe_->Start(this);
 
   event_handler_->OnChannelInitialized(this);
 }
 
+void ChannelDispatcherBase::OnMessageReceived(
+    std::unique_ptr<CompoundBuffer> message) {
+  OnIncomingMessage(std::move(message));
+}
+
+void ChannelDispatcherBase::OnMessagePipeClosed() {
+  event_handler_->OnChannelClosed(this);
+}
+
 }  // namespace protocol
 }  // namespace remoting