diff options
author | Anthony Ramine <n.oxyde@gmail.com> | 2017-09-20 09:59:52 +0200 |
---|---|---|
committer | Anthony Ramine <n.oxyde@gmail.com> | 2017-09-20 10:07:29 +0200 |
commit | 52527d6f9dfaae13458059243d975f5336bdead4 (patch) | |
tree | a9f1b12f82b2aedbc3d4c46851f9b0d09c3e2576 /components/script/dom/websocket.rs | |
parent | f088b708c93e0a131cbfccf5c9b3797018f1c4ee (diff) | |
download | servo-52527d6f9dfaae13458059243d975f5336bdead4.tar.gz servo-52527d6f9dfaae13458059243d975f5336bdead4.zip |
Rename Task to TaskBox
Diffstat (limited to 'components/script/dom/websocket.rs')
-rw-r--r-- | components/script/dom/websocket.rs | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/components/script/dom/websocket.rs b/components/script/dom/websocket.rs index 52b2dcc85d6..bb48cec942e 100644 --- a/components/script/dom/websocket.rs +++ b/components/script/dom/websocket.rs @@ -37,7 +37,7 @@ use std::borrow::ToOwned; use std::cell::Cell; use std::ptr; use std::thread; -use task::{Task, TaskCanceller}; +use task::{TaskBox, TaskCanceller}; use task_source::TaskSource; use task_source::networking::NetworkingTaskSource; @@ -397,9 +397,9 @@ struct ConnectionEstablishedTask { protocol_in_use: Option<String>, } -impl Task for ConnectionEstablishedTask { +impl TaskBox for ConnectionEstablishedTask { /// https://html.spec.whatwg.org/multipage/#feedback-from-the-protocol:concept-websocket-established - fn run(self: Box<Self>) { + fn run_box(self: Box<Self>) { let ws = self.address.root(); // Step 1. @@ -422,13 +422,13 @@ struct BufferedAmountTask { address: Trusted<WebSocket>, } -impl Task for BufferedAmountTask { +impl TaskBox for BufferedAmountTask { // See https://html.spec.whatwg.org/multipage/#dom-websocket-bufferedamount // // To be compliant with standards, we need to reset bufferedAmount only when the event loop // reaches step 1. In our implementation, the bytes will already have been sent on a background // thread. - fn run(self: Box<Self>) { + fn run_box(self: Box<Self>) { let ws = self.address.root(); ws.buffered_amount.set(0); @@ -443,8 +443,8 @@ struct CloseTask { reason: Option<String>, } -impl Task for CloseTask { - fn run(self: Box<Self>) { +impl TaskBox for CloseTask { + fn run_box(self: Box<Self>) { let ws = self.address.root(); if ws.ready_state.get() == WebSocketRequestState::Closed { @@ -483,9 +483,9 @@ struct MessageReceivedTask { message: MessageData, } -impl Task for MessageReceivedTask { +impl TaskBox for MessageReceivedTask { #[allow(unsafe_code)] - fn run(self: Box<Self>) { + fn run_box(self: Box<Self>) { let ws = self.address.root(); debug!("MessageReceivedTask::handler({:p}): readyState={:?}", &*ws, ws.ready_state.get()); |