Rachit2323 5030b3005e tokio-stream: implement FusedStream for various stream adaptors (#8096) ...

`MapWhile` is intentionally excluded because its current implementation
does not track when the closure returns `None` early, making a correct
`is_terminated()` impossible without a separate semantic change.

2026-05-01 14:09:28 +02:00

..

all.rs

chore: replace ready! with std::task::ready! (#6804)

2024-08-29 22:02:56 +02:00

any.rs

chore: replace ready! with std::task::ready! (#6804)

2024-08-29 22:02:56 +02:00

chain.rs

tokio-stream: implement FusedStream for various stream adaptors (#8096)

2026-05-01 14:09:28 +02:00

chunks_timeout.rs

stream: add ChunksTimeout::into_remainder (#7715)

2025-11-06 20:15:10 +08:00

collect.rs

stream: impl FromStream for std::collections::* (#7966)

2026-03-16 16:00:49 +01:00

filter_map.rs

tokio-stream: implement FusedStream for various stream adaptors (#8096)

2026-05-01 14:09:28 +02:00

filter.rs

tokio-stream: implement FusedStream for various stream adaptors (#8096)

2026-05-01 14:09:28 +02:00

fold.rs

chore: replace ready! with std::task::ready! (#6804)

2024-08-29 22:02:56 +02:00

fuse.rs

tokio-stream: implement FusedStream for Fuse (#8090)

2026-04-28 17:33:54 +02:00

map_while.rs

tokio-stream: add StreamExt::map_while (#4351)

2021-12-31 22:53:09 +09:00

map.rs

tokio-stream: implement FusedStream for various stream adaptors (#8096)

2026-05-01 14:09:28 +02:00

merge.rs

tokio-stream: implement FusedStream for various stream adaptors (#8096)

2026-05-01 14:09:28 +02:00

next.rs

stream: add cancel-safety docs to StreamExt::next and try_next (#4715)

2022-05-27 10:28:29 +02:00

peekable.rs

stream: fix link on Peekable (#6861)

2024-09-23 14:56:42 +00:00

skip_while.rs

tokio-stream: implement FusedStream for various stream adaptors (#8096)

2026-05-01 14:09:28 +02:00

skip.rs

tokio-stream: implement FusedStream for various stream adaptors (#8096)

2026-05-01 14:09:28 +02:00

take_while.rs

tokio-stream: implement FusedStream for various stream adaptors (#8096)

2026-05-01 14:09:28 +02:00

take.rs

tokio-stream: implement FusedStream for various stream adaptors (#8096)

2026-05-01 14:09:28 +02:00

then.rs

tokio-stream: implement FusedStream for various stream adaptors (#8096)

2026-05-01 14:09:28 +02:00

throttle.rs

chore: replace ready! with std::task::ready! (#6804)

2024-08-29 22:02:56 +02:00

timeout_repeating.rs

chore: replace ready! with std::task::ready! (#6804)

2024-08-29 22:02:56 +02:00

timeout.rs

chore: replace ready! with std::task::ready! (#6804)

2024-08-29 22:02:56 +02:00

try_next.rs

stream: add cancel-safety docs to StreamExt::next and try_next (#4715)

2022-05-27 10:28:29 +02:00