#data-channel #web-rtc #async #wasm #api-wrapper

async-datachannel-wasm

Async Wrapper for WebRTC datachannel in the browser environment

5 releases

0.2.1 Nov 29, 2022
0.2.0 Mar 9, 2022
0.1.2 Sep 22, 2021
0.1.1 Sep 21, 2021
0.1.0 Sep 21, 2021

#737 in Concurrency

Download history 46/week @ 2023-12-05 30/week @ 2023-12-12 42/week @ 2023-12-19 41/week @ 2023-12-26 60/week @ 2024-01-02 87/week @ 2024-01-09 54/week @ 2024-01-16 27/week @ 2024-01-23 31/week @ 2024-01-30 38/week @ 2024-02-06 53/week @ 2024-02-13 89/week @ 2024-02-20 85/week @ 2024-02-27 101/week @ 2024-03-05 91/week @ 2024-03-12 95/week @ 2024-03-19

420 downloads per month
Used in libp2p-webrtc

Apache-2.0 OR MIT

22KB
359 lines

async-datachannel-wasm

License Cargo Documentation

Async wrapper API for browser provided WebRTC API.


Quickstart

use async_datachannel_wasm::{Message, PeerConnection, RtcConfig};
use futures::io::{AsyncReadExt, AsyncWriteExt, channel::mpsc};

let ice_servers = vec!["stun:stun.l.google.com:19302"];
let conf = RtcConfig::new(&ice_servers);
let (tx_sig_outbound, mut rx_sig_outbound) = mpsc::channel(32);
let (tx_sig_inbound, rx_sig_inbound) = mpsc::channel(32);
let listener = PeerConnection::new(ice_servers, (tx_sig_outbound, rx_sig_inbound))?;

// TODO: Wire up `tx_sig_inbound` and `rx_sig_outbound` to a signalling
// mechanism.

let mut dc = listener.dial("Hangout").await?;
dc.write(b"Hello").await?;

let mut buf = vec![0; 32];
let n = dc.read(&mut buf).await?;
assert_eq!(b"World", &buf[..n]);

License

Licensed under either of

at your option.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

Dependencies

~7–10MB
~194K SLoC