Async Wrapper for datachannel-rs

Oliver Wangler

Last update: Dec 29, 2022

Related tags

Overview

async-datachannel

This repository holds two crates, both of which share (mostly) the same API.

async-datachannel

Async wrapper for the datachannel crate. For a complete example check the native/examples directory.

Note that this crate currently is made to work only with the tokio runtime. If you're interested in supporting other runtimes, let me know.

async-datachannel-wasm

Same API as above, but targets browser environments. Uses the browser provided WebRTC API.

Quickstart

use async_datachannel::{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(&conf, (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

Apache License, Version 2.0 (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0)
MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT)

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.

Async positioned I/O with io_uring.

uring-positioned-io Fully asynchronized positioned I/O with io_uring. Basic Usage let files = vec![File::open("test.txt").unwrap()]; let context = Uri

30 Aug 24, 2022

Async executor for WebAssembly

There are a number of async task executors available in Rust's ecosystem. However, most (if not all?) of them rely on primitives that might not be available or optimal for WebAssembly deployment at the time.

65 Dec 31, 2022

The feature-rich, portable async channel library

The feature-rich, portable async channel library crates.io docs.rs Why use Postage? Includes a rich set of channels. | barrier | broadcast | dispa

221 Dec 26, 2022

Mix async code with CPU-heavy thread pools using Tokio + Rayon

tokio-rayon Mix async code with CPU-heavy thread pools using Tokio + Rayon Resources Documentation crates.io TL;DR Sometimes, you're doing async stuff

74 Jan 2, 2023

Wait for async tasks

taskwait Runtime agnostic way of waiting for async tasks. Features Done: Support for golang's WaitGroup.Add & WaitGroup.Done Done: Support for RAII ba

13 Dec 26, 2022

A single-threaded polling-based Rust async executor suitable for use in games, embedded systems or WASM.

simple async local executor An Enlightware® software. Overview A single-threaded polling-based executor suitable for use in games, embedded systems or

16 Nov 15, 2022

Thread Safe Cache with async loader functions based on tokio-rs

cache-loader-async crates.io The goal of this crate is to provide a thread-safe and easy way to access any data structure which might is stored in a d

13 Nov 30, 2022

Robyn is an async Python backend server with a runtime written in Rust, btw.

1.8k Jan 4, 2023

Fork of async-raft, the Tokio-based Rust implementation of the Raft protocol.

Agreed Fork of async-raft, the Tokio-based Rust implementation of the Raft distributed consensus protocol. Agreed is an implementation of the Raft con

8 Jul 5, 2022

🌱🦀🌱 Trillium is a composable toolkit for building web applications with async rust 🌱🦀🌱

243 Jan 2, 2023

An Async SDR Runtime for Heterogeneous Architectures

FutureSDR An experimental asynchronous SDR runtime for heterogeneous architectures that is: Extensible: custom buffers (supporting accelerators like G

169 Jan 8, 2023

Autogenerated async RPC bindings that instantly connect a JS frontend to a Rust backend service via WebSockets and WASM.

Turbocharger Autogenerated async RPC bindings that instantly connect a JS frontend to a Rust backend service via WebSockets and WASM. See https://gith

28 Jan 2, 2023

Another Async IO Framework based on io_uring

kbio, the Async IO Framework based on io_uring, is used in KuiBaDB to implement async io. Features Support multi-threading concurrent task submission.

59 Oct 31, 2022

A high level async Redis client for Rust built on Tokio and Futures.

108 Jan 1, 2023

A series of test cases to evaluate async Rust on the nrf52840 in terms of power usage and ergonomics.

A series of test cases to evaluate async Rust on the nrf52840 in terms of power usage and ergonomics. This is an experiment that uses unstable features only available on nightly rust.

1 Oct 15, 2021

async-alloc-counter measures max allocations in a future invocation

async-alloc-counter measures max allocations in a future invocation see examples/ for usage This allocator can be used as follows: use async_alloc_cou

2 Dec 3, 2021

Golang like WaitGroup implementation for sync/async Rust.

wg Golang like WaitGroup implementation for sync/async Rust.

8 Dec 6, 2022

single file, std only, async Rust executor

whorl - A single file, std only, async Rust executor whorl was created to teach you how async executors work in Rust. It is not the fastest executor n

459 Dec 29, 2022

Fast multi-producer, multi-consumer unbounded channel with async support.

Hyperbridge Fast multi-producer, multi-consumer unbounded channel with async support. Inspired by crossbeam unbounded channel. Examples Hyperbridge::c

1 Apr 20, 2022

Comments

Expose more functions from datachannel-rs

I added some function with which you can access more of the wrapped datachannel-rs types. In detail, I added the ability to check the current buffer status (useful to check if you're hitting a bandwidth limit) and the ability to initialize a datastream with datachannel-rs' DataChannelInit struct that allows creating unreliable channels etc.

Would be nice if those were available directly from crates.io :)

opened by T0b1-iOS 1
Different crates.io version

Hello, your github source code seems to be on version 0.2.2 while crates.io has version 0.3, did you forget to push on github? crates.io link: https://crates.io/crates/async-datachannel

opened by SnowyCoder 1
Cannot create multiple DataStreams from one PeerConnection
It seems the interface is designed so that it is impossible to create multiple DataStreams for one PeerConnection. Line 240 of lib.rs says:

pub async fn dial(self, label: &str) -> anyhow::Result<DataStream> {

taking self in, disallowing it to be called multiple times. In datachannel-rs there is no such limitation, as can be seen from line 355 of peerconnection.rs:

pub fn create_data_channel_ex<C>( &mut self, label: &str, dc_handler: C, dc_init: &DataChannelInit, ) -> Result<Box<RtcDataChannel<C>>>

The documentation for libdatachannel doesn't outright say that there can be multiple DataChannels, but it does say that rtcCreateDataChannel adds a datachannel to a Peer Connection and in general this is possible.

It can be useful to have e.g. one unordered and unreliable DataChannel paired with an ordered an reliable DataChannel.

~It seems some internal changes are needed to make this happen, peer_con: Arc<Mutex<Box<RtcPeerConnection<ConnInternal>>>> in PeerConnection probably needs to be an Arc as well, for one.~ I guess I misread it :).
opened by eras 1