HeadlessDevToolsClientImpl::DispatchEvent to post a task

headless/lib/browser/headless_devtools_client_impl.h

 // Copyright 2016 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 HEADLESS_LIB_BROWSER_HEADLESS_DEVTOOLS_CLIENT_IMPL_H_
 #define HEADLESS_LIB_BROWSER_HEADLESS_DEVTOOLS_CLIENT_IMPL_H_
 
 #include <unordered_map>
 
+#include "base/memory/weak_ptr.h"
+#include "base/single_thread_task_runner.h"
 #include "content/public/browser/devtools_agent_host_client.h"
 #include "headless/public/domains/accessibility.h"
 #include "headless/public/domains/animation.h"
 #include "headless/public/domains/application_cache.h"
 #include "headless/public/domains/browser.h"
 #include "headless/public/domains/cache_storage.h"
 #include "headless/public/domains/console.h"
 #include "headless/public/domains/css.h"
 #include "headless/public/domains/database.h"
 #include "headless/public/domains/debugger.h"
@@ skipping 120 matching lines @@
 
   template <typename CallbackType>
   void SendMessageWithParams(const char* method,
                              std::unique_ptr<base::Value> params,
                              CallbackType callback);
 
   template <typename CallbackType>
   void SendMessageWithoutParams(const char* method, CallbackType callback);
 
   bool DispatchMessageReply(const base::DictionaryValue& message_dict);
-  bool DispatchEvent(const base::DictionaryValue& message_dict);
+
+  using EventHandler = base::Callback<void(const base::Value&)>;
+  using EventHandlerMap = std::unordered_map<std::string, EventHandler>;
+
+  bool DispatchEvent(std::unique_ptr<base::Value> owning_message,
+                     const base::DictionaryValue& message_dict);
+  void DispatchEventTask(std::unique_ptr<base::Value> owning_message,
+                         const EventHandler* event_handler,
+                         const base::DictionaryValue* result_dict);
 
   content::DevToolsAgentHost* agent_host_;  // Not owned.
   int next_message_id_;
   std::unordered_map<int, Callback> pending_messages_;
-  std::unordered_map<std::string, base::Callback<void(const base::Value&)>>
-      event_handlers_;
+
+  EventHandlerMap event_handlers_;
 
   accessibility::ExperimentalDomain accessibility_domain_;
   animation::ExperimentalDomain animation_domain_;
   application_cache::ExperimentalDomain application_cache_domain_;
   browser::ExperimentalDomain browser_domain_;
   cache_storage::ExperimentalDomain cache_storage_domain_;
   console::ExperimentalDomain console_domain_;
   css::ExperimentalDomain css_domain_;
   database::ExperimentalDomain database_domain_;
   debugger::ExperimentalDomain debugger_domain_;
@@ skipping 12 matching lines @@
   memory::ExperimentalDomain memory_domain_;
   network::ExperimentalDomain network_domain_;
   page::ExperimentalDomain page_domain_;
   profiler::ExperimentalDomain profiler_domain_;
   rendering::ExperimentalDomain rendering_domain_;
   runtime::ExperimentalDomain runtime_domain_;
   security::ExperimentalDomain security_domain_;
   service_worker::ExperimentalDomain service_worker_domain_;
   tracing::ExperimentalDomain tracing_domain_;
   worker::ExperimentalDomain worker_domain_;
+  scoped_refptr<base::SingleThreadTaskRunner> browser_main_thread_;
+  base::WeakPtrFactory<HeadlessDevToolsClientImpl> weak_ptr_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(HeadlessDevToolsClientImpl);
 };
 
 }  // namespace headless
 
 #endif  // HEADLESS_LIB_BROWSER_HEADLESS_DEVTOOLS_CLIENT_IMPL_H_