diff options
Diffstat (limited to 'components/script/dom/websocket.rs')
-rw-r--r-- | components/script/dom/websocket.rs | 10 |
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; } |