aboutsummaryrefslogtreecommitdiffstats
path: root/components/script/dom/websocket.rs
diff options
context:
space:
mode:
Diffstat (limited to 'components/script/dom/websocket.rs')
-rw-r--r--components/script/dom/websocket.rs10
1 files changed, 5 insertions, 5 deletions
diff --git a/components/script/dom/websocket.rs b/components/script/dom/websocket.rs
index 949f1c683a2..5f86ec6b0cd 100644
--- a/components/script/dom/websocket.rs
+++ b/components/script/dom/websocket.rs
@@ -237,7 +237,7 @@ impl WebSocket {
// Step 7.
let ws = WebSocket::new(global, resource_url.clone());
- let address = Trusted::new(ws.r(), global.networking_thread_source());
+ let address = Trusted::new(ws.r(), global.networking_task_source());
let connect_data = WebSocketConnectData {
resource_url: resource_url.clone(),
@@ -264,7 +264,7 @@ impl WebSocket {
*ws.sender.borrow_mut() = Some(dom_action_sender);
let moved_address = address.clone();
- let sender = global.networking_thread_source();
+ let sender = global.networking_task_source();
thread::spawn(move || {
while let Ok(event) = dom_event_receiver.recv() {
match event {
@@ -307,7 +307,7 @@ impl WebSocket {
};
let global = self.global();
- let chan = global.r().networking_thread_source();
+ let chan = global.r().networking_task_source();
let address = Trusted::new(self, chan.clone());
match data_byte_len.checked_add(self.buffered_amount.get()) {
@@ -433,7 +433,7 @@ impl WebSocketMethods for WebSocket {
self.ready_state.set(WebSocketRequestState::Closing);
let global = self.global();
- let sender = global.r().networking_thread_source();
+ let sender = global.r().networking_task_source();
let address = Trusted::new(self, sender.clone());
fail_the_websocket_connection(address, sender);
}
@@ -467,7 +467,7 @@ impl Runnable for ConnectionEstablishedTask {
// Step 1: Protocols.
if !self.protocols.is_empty() && self.headers.get::<WebSocketProtocol>().is_none() {
- let sender = global.r().networking_thread_source();
+ let sender = global.r().networking_task_source();
fail_the_websocket_connection(self.addr, sender);
return;
}