fluencelabs/wasm-bindgen
1
0
Fork 0
mirror of https://github.com/fluencelabs/wasm-bindgen synced 2025-06-21 00:36:33 +00:00
Code Issues Projects Releases Wiki Activity

added websockets example to the guide

Browse Source
This commit is contained in:
ibaryshnikov
2019-06-01 16:17:50 +03:00
parent e16bb9cd38
commit cbedf0bba0
6 changed files with 43 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
examples/websockets/src/lib.rs
View File

@ -14,16 +14,17 @@ extern "C" {
#[wasm_bindgen(start)]
pub fn start_websocket() -> Result<(), JsValue> {
// Assuming, you run a WebSockets server at localhost:8081
// You'll also need to disable CORS in case of serving this example from
// the different `host:port` then your WebSockets server
let ws = WebSocket::new("ws://localhost:8081")
.expect("should create a socket");
// Connect to an echo server
let ws = WebSocket::new("wss://echo.websocket.org")?;
// create callback
let onmessage_callback = Closure::wrap(Box::new(move |e: MessageEvent| {
// handle message
console_log!("message event, received data {:?}", e.data());
let response = e
.data()
.as_string()
.expect("Can't convert received data to a string");
console_log!("message event, received data: {:?}", response);
}) as Box<dyn FnMut(MessageEvent)>);
// set message event handler on WebSocket
ws.set_onmessage(Some(onmessage_callback.as_ref().unchecked_ref()));
@ -31,7 +32,7 @@ pub fn start_websocket() -> Result<(), JsValue> {
onmessage_callback.forget();
let onerror_callback = Closure::wrap(Box::new(move |e: ErrorEvent| {
console_log!("error event {:?}", e);
console_log!("error event: {:?}", e);
}) as Box<dyn FnMut(ErrorEvent)>);
ws.set_onerror(Some(onerror_callback.as_ref().unchecked_ref()));
onerror_callback.forget();
@ -40,8 +41,8 @@ pub fn start_websocket() -> Result<(), JsValue> {
let onopen_callback = Closure::wrap(Box::new(move |_| {
console_log!("socket opened");
match cloned_ws.send_with_str("ping") {
Ok(_) => console_log!("message sent successfully"),
Err(err) => console_log!("error sending message {:?}", err),
Ok(_) => console_log!("message successfully sent"),
Err(err) => console_log!("error sending message: {:?}", err),
}
}) as Box<dyn FnMut(JsValue)>);
ws.set_onopen(Some(onopen_callback.as_ref().unchecked_ref()));