Update navigator.services API to use the new services.onconnect event [2/3].

content/child/navigator_connect/service_port_dispatcher_impl.h

Index: content/child/navigator_connect/service_port_dispatcher_impl.h
diff --git a/content/child/navigator_connect/service_port_dispatcher_impl.h b/content/child/navigator_connect/service_port_dispatcher_impl.h
new file mode 100644
index 0000000000000000000000000000000000000000..079e07731a87f26c3c7ea96beb8325a073a7df9a
--- /dev/null
+++ b/content/child/navigator_connect/service_port_dispatcher_impl.h
@@ -0,0 +1,55 @@
+// Copyright 2015 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.
+
+#ifndef CONTENT_CHILD_NAVIGATOR_CONNECT_SERVICE_PORT_DISPATCHER_IMPL_H_
+#define CONTENT_CHILD_NAVIGATOR_CONNECT_SERVICE_PORT_DISPATCHER_IMPL_H_
+
+#include "base/macros.h"
+#include "base/memory/weak_ptr.h"
+#include "content/child/worker_task_runner.h"
+#include "content/common/service_port_service.mojom.h"
+#include "third_party/mojo/src/mojo/public/cpp/bindings/strong_binding.h"
+
+namespace blink {
+class WebServiceWorkerContextProxy;
+}
+
+namespace content {
+
+// Mojo service that dispatches ServicePort related events to a service worker.
+// Instances are always created on a worker thread, and all methods are only
+// called on that same thread. Lifetime of this class is tied to both the mojo
+// channel and the lifetime of the worker thread. If either the channel is
+// disconnected or the worker thread stops the instance deletes itself.
+class ServicePortDispatcherImpl : public ServicePortDispatcher,
+                                  public WorkerTaskRunner::Observer {
+ public:
+  static void Create(base::WeakPtr<blink::WebServiceWorkerContextProxy> proxy,
+                     mojo::InterfaceRequest<ServicePortDispatcher> request);
+
+  ~ServicePortDispatcherImpl() override;
+
+ private:
+  ServicePortDispatcherImpl(
+      base::WeakPtr<blink::WebServiceWorkerContextProxy> proxy,
+      mojo::InterfaceRequest<ServicePortDispatcher> request);
+
+  // WorkerTaskRunner::Observer implementation.
+  void OnWorkerRunLoopStopped() override;
+
+  // ServicePortDispatcher implementation.
+  void Connect(const mojo::String& target_url,
+               const mojo::String& origin,
+               int32_t port_id,
+               const ConnectCallback& callback) override;
+
+  mojo::StrongBinding<ServicePortDispatcher> binding_;
+  base::WeakPtr<blink::WebServiceWorkerContextProxy> proxy_;
+
+  DISALLOW_COPY_AND_ASSIGN(ServicePortDispatcherImpl);
+};
+
+}  // namespace content
+
+#endif  // CONTENT_CHILD_NAVIGATOR_CONNECT_SERVICE_PORT_DISPATCHER_IMPL_H_