Agent Rex

An async Stream-based FRP-like library for Rust.

This library provides composable stream operators similar to RxJS/Most.js, built on top of the futures crate's Stream trait.

Runtime Agnostic

Most operators are runtime-agnostic and work with any async executor. For time-based operations, we provide generic versions that accept a sleep function parameter, plus feature-flagged implementations for specific runtimes (tokio, smol, async-std).