`ianaio-net`

API Docs | Contributing | Chat

_{Built with 🦀🕸 by The IanaIO Rust and WebAssembly Working Group}

HTTP requests library for WASM Apps. It provides idiomatic Rust bindings for the `web_sys` [`fetch`](https://developer.mozilla.org/en-US/docs/Web/API/Fetch_API), [`WebSocket`](https://developer.mozilla.org/en-US/docs/Web/API/WebSocket) and [`EventSource`](https://developer.mozilla.org/en-US/docs/Web/API/EventSource) APIs. ## Examples ### HTTP ```rust let resp = Request::get("/path") .send() .await .unwrap(); assert_eq!(resp.status(), 200); ``` ### WebSocket ```rust use ianaio_net::websocket::{Message, futures::WebSocket}; use wasm_bindgen_futures::spawn_local; use futures::{SinkExt, StreamExt}; let mut ws = WebSocket::open("wss://echo.websocket.org").unwrap(); let (mut write, mut read) = ws.split(); spawn_local(async move { write.send(Message::Text(String::from("test"))).await.unwrap(); write.send(Message::Text(String::from("test 2"))).await.unwrap(); }); spawn_local(async move { while let Some(msg) = read.next().await { console_log!(format!("1. {:?}", msg)) } console_log!("WebSocket Closed") }) ``` ### EventSource ```rust use ianaio_net::eventsource::futures::EventSource; use wasm_bindgen_futures::spawn_local; use futures::{stream, StreamExt}; let mut es = EventSource::new("http://api.example.com/ssedemo.php").unwrap(); let stream_1 = es.subscribe("some-event-type").unwrap(); let stream_2 = es.subscribe("another-event-type").unwrap(); spawn_local(async move { let mut all_streams = stream::select(stream_1, stream_2); while let Some(Ok((event_type, msg))) = all_streams.next().await { console_log!(format!("1. {}: {:?}", event_type, msg)) } console_log!("EventSource Closed"); }) ```