4 releases

0.1.3 Aug 1, 2023
0.1.2 Jul 27, 2023
0.1.1 Jul 25, 2023
0.1.0 Jul 4, 2023

#1564 in Asynchronous

Download history 578/week @ 2024-11-15 748/week @ 2024-11-22 1035/week @ 2024-11-29 909/week @ 2024-12-06 814/week @ 2024-12-13 681/week @ 2024-12-20 376/week @ 2024-12-27 1044/week @ 2025-01-03 1049/week @ 2025-01-10 844/week @ 2025-01-17 976/week @ 2025-01-24 1779/week @ 2025-01-31 1373/week @ 2025-02-07 1316/week @ 2025-02-14 1070/week @ 2025-02-21 1174/week @ 2025-02-28

5,185 downloads per month
Used in matrix-sdk-ui

MPL-2.0 license

12KB
241 lines

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

lib.rs:

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.

Dependencies

~71KB