/* This Source Code Form is subject to the terms of the Mozilla Public * License, v. 2.0. If a copy of the MPL was not distributed with this * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ use dom::bindings::refcounted::Trusted; use dom::event::{EventBubbles, EventCancelable, EventRunnable, SimpleEventRunnable}; use dom::eventtarget::EventTarget; use script_thread::{MainThreadScriptMsg, Runnable, ScriptThread}; use std::result::Result; use std::sync::mpsc::Sender; use string_cache::Atom; use task_source::TaskSource; #[derive(JSTraceable, Clone)] pub struct DOMManipulationTaskSource(pub Sender); impl TaskSource for DOMManipulationTaskSource { fn queue(&self, msg: DOMManipulationTask) -> Result<(), ()> { self.0.send(MainThreadScriptMsg::DOMManipulation(msg)).map_err(|_| ()) } } impl DOMManipulationTaskSource { pub fn queue_event(&self, target: &EventTarget, name: Atom, bubbles: EventBubbles, cancelable: EventCancelable) { let target = Trusted::new(target); let runnable = box EventRunnable { target: target, name: name, bubbles: bubbles, cancelable: cancelable, }; let _ = self.queue(DOMManipulationTask(runnable)); } pub fn queue_simple_event(&self, target: &EventTarget, name: Atom) { let target = Trusted::new(target); let runnable = box SimpleEventRunnable { target: target, name: name, }; let _ = self.queue(DOMManipulationTask(runnable)); } } pub struct DOMManipulationTask(pub Box); impl DOMManipulationTask { pub fn handle_task(self, script_thread: &ScriptThread) { if !self.0.is_cancelled() { self.0.main_thread_handler(script_thread); } } }