1
0
Fork
You've already forked async-rx
0
No description
  • Rust 100%
2026年05月02日 13:06:59 +02:00
.github/workflows Add CI 2023年07月25日 11:28:09 +02:00
src chore: Replace Switch::outer_stream_is_closed by FusedStream. 2026年04月17日 10:28:24 +02:00
tests/it chore: Replace Switch::outer_stream_is_closed by FusedStream. 2026年04月17日 10:28:24 +02:00
.clippy.toml Add clippy.toml 2023年07月25日 11:25:06 +02:00
.gitignore Initial commit 2023年07月04日 20:40:09 +02:00
.rustfmt.toml Initial commit 2023年07月04日 20:40:09 +02:00
Cargo.toml Publish v0.2.1 2026年05月02日 13:06:59 +02:00
CHANGELOG.md Publish v0.2.1 2026年05月02日 13:06:59 +02:00
LICENSE Initial commit 2023年07月04日 20:40:09 +02:00
README.md Add StreamExt::switch to README.md 2026年02月13日 21:43:25 +01:00

async-rx

Utility functions for async reactive programming.

This crate is intentionally very small as it only provides utilities that are not already found in futures-util. It is meant as a supplement, not a replacement for the existing well-known futures crates.

Currently provided functionality:

  • StreamExt::dedup for deduplicating consecutive equal items
  • StreamExt::dedup_by_key for deduplicating consecutive items with an equal property
  • StreamExt::batch_with for flexible batching of the stream's items
  • StreamExt::switch for switching a stream of streams