Tethys Svensson
c8116ecd7b
stream: work around the rustc bug in StreamExt::collect ( #7754 )
2025-12-05 10:24:29 +08:00
Lucas Black
8ccf2fb92e
ci: unfreeze wasm tests from rustc 1.88.0 ( #7537 )
2025-09-26 21:29:01 +08:00
sharpened-nacho
c8f3539bc1
stream: make stream adapters public ( #6658 )
2024-07-02 20:49:34 +00:00
Yotam Ofek
161ecec156
stream: fix typo in peekable docs ( #6130 )
2023-11-05 22:51:09 +01:00
ad hoc
65f861f478
stream: add StreamExt::peekable ( #6095 )
2023-11-01 17:32:35 +00:00
Alice Ryhl
58acb56a17
ci: update nightly to 2023-10-21 ( #6103 )
2023-10-24 14:15:25 +00:00
Jiahao XU
5128601898
ci: fix clippy warnings ( #5891 )
...
Signed-off-by: Jiahao XU <[email protected]
2023-07-28 12:05:32 +02:00
jrray
e789b61424
stream: add StreamExt::timeout_repeating ( #5577 )
2023-04-24 09:27:24 +02:00
afajl
1e437595a3
stream: document that throttle operates on ms granularity ( #5101 )
2022-10-14 23:45:16 +02:00
Hayden Stainsby
485ca3e37c
stream: add track_caller to public APIs ( #4786 )
...
Functions that may panic can be annotated with `#[track_caller]` so that
in the event of a panic, the function where the user called the
panicking function is shown instead of the file and line within Tokio
source.
This change adds `#[track_caller]` to all the non-unstable public APIs
in tokio-stream (only `chunks_timeout` in `StreamExt`) where the
documentation describes how this function may panic due to incorrect
input.
A test has been included to cover the panic.
Refs: #4413
2022-06-22 17:27:23 +00:00
Richard Zak
f26ce08f37
chore: fix spelling ( #4769 )
...
Signed-off-by: Richard Zak <[email protected]
2022-06-15 16:06:50 +00:00
jefftt
7011a68343
time: add StreamExt::chunks_timeout ( #4695 )
2022-06-06 16:16:50 +02:00
Gus Wynn
05cbfae177
stream: add cancel-safety docs to StreamExt::next and try_next ( #4715 )
2022-05-27 10:28:29 +02:00
Alisue
014be71cca
stream: expose Elapsed error ( #4502 )
2022-03-02 13:53:21 +01:00
Braulio Valdivielso Martínez
fb35c83944
tokio-stream: add StreamExt::map_while ( #4351 )
...
Fixes #4337
Rust 1.57 stabilized the `Iterator::map_while` API. This PR adds the
same functionality to the `StreamExt` trait, to keep parity.
2021-12-31 22:53:09 +09:00
Alice Ryhl
dda8da75d0
stream: add StreamExt::then ( #4355 )
2021-12-30 15:28:13 +01:00
Taiki Endo
08ed41f339
chore: fix typos ( #3907 )
2021-07-01 02:06:56 +09:00
Alice Ryhl
4d7b73f5b3
chore: create stream_ext module ( #3342 )
2020-12-26 17:05:51 +01:00
Tethys Svensson