#tokio-stream #async #streammap

streammap-ext

StreamMap of Tokio with altered next that returns when stream is dropped

1 unstable release

0.1.0 Jul 20, 2022

#1786 in Asynchronous

Download history 771/week @ 2025-10-02 1404/week @ 2025-10-09 938/week @ 2025-10-16 1442/week @ 2025-10-23 1003/week @ 2025-10-30 981/week @ 2025-11-06 865/week @ 2025-11-13 1585/week @ 2025-11-20 2283/week @ 2025-11-27 1920/week @ 2025-12-04 1116/week @ 2025-12-11 1991/week @ 2025-12-18 1502/week @ 2025-12-25 1218/week @ 2026-01-01 2948/week @ 2026-01-08 1866/week @ 2026-01-15

7,628 downloads per month

MIT license

23KB
223 lines

streammap-ext

This is a fork of StreamMap from tokio-stream crate. The only difference between the implementations is that this version of StreamMap next returns Option<K,Option<V>> instead of Option<K,V>. This is to allow the developer to be aware when a stream is being dropped from the StreamMap, without the need to implement a Drop trait which can be troublesome in some cases (e.g. the drop flow requires async code).

After releasing this crate, I'll open a discussion to consider how to contribute it back to the original crate (as a different name, maybe a PhantomData that marks behavior, or maybe change the current behavior to this).

LICENSE

MIT - Same as source, all copy right goes to Tokio Contributors as this is a fork of tokio-stream crate.

Dependencies

~2–2.7MB
~38K SLoC