aboutsummaryrefslogtreecommitdiffstats
path: root/components/script/dom/websocket.rs
diff options
context:
space:
mode:
authorChristian Poveda <christianpoveda@protonmail.com>2018-03-25 10:00:08 -0500
committerChristian Poveda <christianpoveda@protonmail.com>2018-03-25 10:01:33 -0500
commitbff887c5a6d5d1077922db7071fc4246ad8acc22 (patch)
tree45609c6714bc0bd0f484bd7c3268a4f88d5a8080 /components/script/dom/websocket.rs
parent3ce3f39383c8217a30b15d27f3121f96bbe0014d (diff)
downloadservo-bff887c5a6d5d1077922db7071fc4246ad8acc22.tar.gz
servo-bff887c5a6d5d1077922db7071fc4246ad8acc22.zip
Websockets send typed arrays now
Diffstat (limited to 'components/script/dom/websocket.rs')
-rw-r--r--components/script/dom/websocket.rs31
1 files changed, 30 insertions, 1 deletions
diff --git a/components/script/dom/websocket.rs b/components/script/dom/websocket.rs
index 6acb82c863c..c072f4bb010 100644
--- a/components/script/dom/websocket.rs
+++ b/components/script/dom/websocket.rs
@@ -24,7 +24,8 @@ use dom_struct::dom_struct;
use ipc_channel::ipc::{self, IpcReceiver, IpcSender};
use js::jsapi::{JSAutoCompartment, JSObject};
use js::jsval::UndefinedValue;
-use js::typedarray::{ArrayBuffer, CreateWith};
+use js::rust::CustomAutoRooterGuard;
+use js::typedarray::{ArrayBuffer, ArrayBufferView, CreateWith};
use net_traits::{CoreResourceMsg, FetchChannels};
use net_traits::{WebSocketDomAction, WebSocketNetworkEvent};
use net_traits::MessageData;
@@ -350,6 +351,34 @@ impl WebSocketMethods for WebSocket {
Ok(())
}
+ // https://html.spec.whatwg.org/multipage/#dom-websocket-send
+ fn Send__(&self, array: CustomAutoRooterGuard<ArrayBuffer>) -> ErrorResult {
+ let bytes = array.to_vec();
+ let data_byte_len = bytes.len();
+ let send_data = self.send_impl(data_byte_len as u64)?;
+
+ if send_data {
+ let mut other_sender = self.sender.borrow_mut();
+ let my_sender = other_sender.as_mut().unwrap();
+ let _ = my_sender.send(WebSocketDomAction::SendMessage(MessageData::Binary(bytes)));
+ }
+ Ok(())
+ }
+
+ // https://html.spec.whatwg.org/multipage/#dom-websocket-send
+ fn Send___(&self, array: CustomAutoRooterGuard<ArrayBufferView>) -> ErrorResult {
+ let bytes = array.to_vec();
+ let data_byte_len = bytes.len();
+ let send_data = self.send_impl(data_byte_len as u64)?;
+
+ if send_data {
+ let mut other_sender = self.sender.borrow_mut();
+ let my_sender = other_sender.as_mut().unwrap();
+ let _ = my_sender.send(WebSocketDomAction::SendMessage(MessageData::Binary(bytes)));
+ }
+ Ok(())
+ }
+
// https://html.spec.whatwg.org/multipage/#dom-websocket-close
fn Close(&self, code: Option<u16>, reason: Option<USVString>) -> ErrorResult {
if let Some(code) = code {