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

• actix

  15 8,558 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.

• InfluxDB

  www.influxdata.com featured

  Purpose built for real-time analytics at any scale. InfluxDB Platform is powered by columnar analytics, optimized for cost-efficient storage, and built with open data standards.

  

• wg-async

  8 377 6.2 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.

Suggest a related project