How should I structure an async/await/futures program with multiple event sources and mutable state?

• actix

  15 8,406 8.1 Rust

  Actor framework for Rust.

  

I'd just use Actix for that. Make your state an actor and make it a StreamHandler for each of these sources, and that's it - now you just implement the business logic for handling each message in the StreamHandler::handle methods.

• wg-async

  8 365 5.9 Rust

  Working group dedicated to improving the foundations of Async I/O in Rust

  

Provided the futures you're selecting over are cancellation safe the plain loop over select! should be fine. Multiple channels in particular are safe to select over - if you have futures that aren't cancellation safe, you can just wrap them up in a task on the end of a channel and then select on that.

• InfluxDB

  www.influxdata.com featured

  Power Real-Time Data Analytics at Scale. Get real-time insights from all types of time series data with InfluxDB. Ingest, query, and analyze billions of data points in real-time with unbounded cardinality.

  

Suggest a related project