Zettroke
129f9fc0c8
codec: fix incorrect handling of invalid utf-8 in LinesCodec::decode_eof ( #7011 )
2024-12-04 10:18:14 +00:00
Hamir Mahal
d4178cf349
tokio: avoid positional fmt params when possible ( #6978 )
2024-11-18 13:50:58 +01:00
Havish Maka
11f66f43a0
chore: replace ready! with std::task::ready! ( #6804 )
2024-08-29 22:02:56 +02:00
Yotam Ofek
c9fad08466
codec: fix typo in the docs for Encoder::Error ( #6800 )
2024-08-27 09:08:22 +02:00
Vrtgs
17819062e2
tokio: update code according to new MSRV ( #6764 )
2024-08-11 11:55:22 +02:00
Hai-Hsin
06582776a5
codec: fix length_delimited docs examples ( #6638 )
2024-06-23 13:52:51 +09:00
Michael Scholten
daa89017da
ci: fix new clippy warnings ( #6569 )
2024-05-18 10:09:37 +02:00
Alice Ryhl
2a0df5fb05
ci: bump nightly to nightly-2024-05-05 ( #6538 )
2024-05-05 15:43:11 +00:00
Jens Reidel
d298049299
codec: make tracing feature optional for codecs ( #6434 )
...
Signed-off-by: Jens Reidel <[email protected]
2024-03-30 18:20:05 +01:00
M.Amin Rayej
deff2524c3
util: document cancel safety of SinkExt::send and StreamExt::next ( #6417 )
2024-03-25 01:53:01 +03:30
M.Amin Rayej
8342e4b524
util: assert compatibility between LengthDelimitedCodec options ( #6414 )
2024-03-24 01:12:24 +03:30
M.Amin Rayej
e25d661e08
util: add examples for FramedRead and FramedWrite ( #6310 )
2024-02-11 02:38:44 +03:30
Patrick McGleenon and Rafael Bachmann
e392c4ff1e
chore: update CI to clippy 1.76 ( #6334 )
...
Co-authored-by: Rafael Bachmann <[email protected]
2024-02-10 10:45:40 +01:00
Owen Leung
131e7b4e49
ci: add spellchecking ( #6297 )
2024-01-29 10:53:43 +01:00
Weijia Jiang
a6be73eecb
codec: document the line ending used by LinesCodec ( #5982 )
2023-09-08 15:59:48 +02:00
Alice Ryhl
36fdccc3bc
util: Revert "remove Encoder bound on FramedParts constructor" ( #5450 )
...
This reverts commit ae69d11d1f
2023-02-12 11:55:41 +01:00
Matt Fellenz
ae69d11d1f
util: remove Encoder bound on FramedParts constructor ( #5280 )
2022-12-09 11:12:42 +00:00
crusader-mike
cbbf81b922
codec: expose backpressure_boundary in Framed API ( #5124 )
2022-10-29 14:59:22 +00:00
Yotam Ofek
1c823093cb
codec: fix LengthDelimitedCodec buffer over-reservation ( #4997 )
2022-09-11 15:58:51 +02:00
Richard Zak
f26ce08f37
chore: fix spelling ( #4769 )
...
Signed-off-by: Richard Zak <[email protected]
2022-06-15 16:06:50 +00:00
Gus Wynn
413c812ac8
util: switch tokio-util from log to tracing ( #4539 )
2022-02-26 12:47:04 +01:00
Nikolai Vazquez
3f508d1622
codec: add length_field_type to LengthDelimitedCodec builder ( #4508 )
2022-02-23 11:46:52 +01:00
Sunyeop Lee
0b05ef638d
codec: implement Encoder<BytesMut> for BytesCodec ( #4465 )
2022-02-08 09:11:24 -05:00
Luiz Carlos
2a5071fc2d
feat: implement Framed::map_codec ( #4427 )
2022-01-27 12:37:30 +01:00
Tom Dohrmann
4a12163d7c
util: add mutable reference getters for codecs to pinned Framed ( #4372 )
2022-01-03 22:21:43 +01:00
David Kleingeld
dc1894105b
codec: improve Builder::max_frame_length docs ( #4352 )
2021-12-28 15:08:37 +01:00
Bhargav
0c68b89452
codec: update stream impl for Framed to return None after Err ( #4166 )
2021-10-26 16:56:15 +02:00
Pablo Sichert
98e78a6f7b
codec: implement Clone for LengthDelimitedCodec ( #4089 )
2021-09-07 13:51:35 +02:00
Taiki Endo
08ed41f339
chore: fix typos ( #3907 )
2021-07-01 02:06:56 +09:00
somethingelseentirely
8ed825fd49
util: makes Framed and FramedStream resumable after eof ( #3272 )
2021-03-22 09:09:01 +01:00
cssivision
bcb95db4e2
chore: fix clippy warnings in newer versions ( #3588 )
2021-03-10 08:42:24 +01:00
r-zig
5756a005a6
codec: LinesCodec should only return MaxLineLengthExceeded once per line ( #3556 )
2021-02-25 23:21:59 +01:00
r-zig
c9d2a36c7b
codec: AnyDelimiter codec ( #3406 )
2021-02-23 16:56:11 +01:00
Alice Ryhl
ee1f0c473f
util: remove tokio-stream dependency from tokio-util ( #3487 )
2021-01-31 11:08:40 +01:00
David Raifaizen
2fe2f0401b
util: expose FramedWrite/Framed::write_buffer/write_buffer_mut
2021-01-08 23:20:07 +01:00
Daiki Mizukami
36918e05e5
util: add more get_{ref,mut,pin_mut} methods ( #3364 )
...
This commit adds:
- Framed::get_pin_mut
- FramedRead::get_pin_mut
- FramedWrite::get_pin_mut
- StreamReader::get_ref
- StreamReader::get_mut
- StreamReader::get_pin_mut
- StreamReader::into_inner
2021-01-01 13:05:15 +01:00
Taiki Endo
ce0e9c67cf
chore: Revert "use #[non_exhaustive] instead of private unit field" ( #3323 )
...
This reverts commit 575938d457
2020-12-23 08:27:58 -08:00
Taiki Endo
575938d457
chore: use #[non_exhaustive] instead of private unit field ( #3320 )
2020-12-23 22:48:33 +09:00
Alice Ryhl
78f2340d25
tokio: remove prelude ( #3299 )
...
Closes : #3257
2020-12-19 11:42:24 -08:00
Alice Ryhl and Lucio Franco
3ecaf9fd9a
codec: write documentation for codec ( #3283 )
...
Co-authored-by: Lucio Franco <[email protected]
2020-12-18 21:32:27 +01:00
Lucio Franco
8efa62013b
Move stream items into tokio-stream ( #3277 )
...
This change removes all references to `Stream` from
within the `tokio` crate and moves them into a new
`tokio-stream` crate. Most types have had their
`impl Stream` removed as well in-favor of their
inherent methods.
Closes #2870
2020-12-15 20:24:38 -08:00
Eliza Weisman
647299866a
util: add writev-aware poll_write_buf ( #3156 )
...
## Motivation
In Tokio 0.2, `AsyncRead` and `AsyncWrite` had `poll_write_buf` and
`poll_read_buf` methods for reading and writing to implementers of
`bytes` `Buf` and `BufMut` traits. In 0.3, these were removed, but
`poll_read_buf` was added as a free function in `tokio-util`. However,
there is currently no `poll_write_buf`.
Now that `AsyncWrite` has regained support for vectored writes in #3149 ,
there's a lot of potential benefit in having a `poll_write_buf` that
uses vectored writes when supported and non-vectored writes when not
supported, so that users don't have to reimplement this.
## Solution
This PR adds a `poll_write_buf` function to `tokio_util::io`, analogous
to the existing `poll_read_buf` function.
This function writes from a `Buf` to an `AsyncWrite`, advancing the
`Buf`'s internal cursor. In addition, when the `AsyncWrite` supports
vectored writes (i.e. its `is_write_vectored` method returns `true`),
it will use vectored IO.
I copied the documentation for this functions from the docs from Tokio
0.2's `AsyncWrite::poll_write_buf` , with some minor modifications as
appropriate.
Finally, I fixed a minor issue in the existing docs for `poll_read_buf`
and `read_buf`, and updated `tokio_util::codec` to use `poll_write_buf`.
Signed-off-by: Eliza Weisman <[email protected]
2020-12-03 11:19:16 -08:00
漂流
874fc3320b
codec: add read_buffer_mut to FramedRead ( #3166 )
2020-11-24 09:39:16 +01:00
Dirkjan Ochtman
2b23aa7389
util: add back public poll_read_buf() function ( #3079 )
...
This was accidentally removed in #3064 .
2020-11-01 10:22:22 +01:00
Carl Lerche
d78655337a
Revert "util: upgrade tokio-util to bytes 0.6 ( #3052 )" ( #3060 )
...
This reverts commit fe2b997#3059 ).
2020-10-27 13:42:00 -07:00
Dirkjan Ochtman
fe2b997675
util: upgrade tokio-util to bytes 0.6 ( #3052 )
2020-10-27 09:30:29 +01:00
8880222036
rt: Remove threaded_scheduler() and basic_scheduler() ( #2876 )
...
Co-authored-by: Alice Ryhl <[email protected] [email protected]
2020-10-12 13:44:54 -04:00
Carl Lerche
4186b0aa38
io: remove poll_{read,write}_buf from traits ( #2882 )
...
These functions have object safety issues. It also has been decided to
avoid vectored operations on the I/O traits. A later PR will bring back
vectored operations on specific types that support them.
Refs: #2879 , #2716
2020-09-24 17:26:03 -07:00
Alice Ryhl
b094ee90e2
chore: fix new manual_non_exhaustive clippy lint ( #2669 )
...
Our minimum supported Rust version does not allow switching to `#[non_exhaustive]`.
2020-07-20 09:23:19 -07:00
xliiv
e70a1b6d64
docs: use intra-links in the docs ( #2575 )
2020-05-31 18:49:04 +02:00
Zettroke