aboutsummaryrefslogtreecommitdiffstats
path: root/components/script/dom/websocket.rs
diff options
context:
space:
mode:
authorAnthony Ramine <n.oxyde@gmail.com>2017-09-20 09:59:52 +0200
committerAnthony Ramine <n.oxyde@gmail.com>2017-09-20 10:07:29 +0200
commit52527d6f9dfaae13458059243d975f5336bdead4 (patch)
treea9f1b12f82b2aedbc3d4c46851f9b0d09c3e2576 /components/script/dom/websocket.rs
parentf088b708c93e0a131cbfccf5c9b3797018f1c4ee (diff)
downloadservo-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.rs18
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());