Alice Ryhl
3549092a0c
docs: fix tokio-stream features not being displayed ( #3378 )
2021-01-05 11:43:09 +01:00
Alice Ryhl
3b840fb305
stream: remove path deps ( #3376 )
2021-01-04 21:04:22 +01:00
Alice Ryhl
4beb1862ac
chore: prepare tokio-stream 0.1.1 ( #3374 )
2021-01-04 19:46:01 +01:00
Alice Ryhl
7f17822ed9
stream: add Stream wrappers in tokio-stream ( #3343 )
2021-01-04 19:03:18 +01:00
cssivision
3b6bee822d
net: add try_read_buf and try_recv_buf ( #3351 )
2021-01-02 10:37:34 +01:00
Rob Ede
56272b2ec7
stream: move async-stream to dev-deps ( #3366 )
2021-01-02 13:43:41 +09:00
John-John Tedro
53707f5d9d
sync: remove underused internal Borrow wrapper ( #3363 )
2021-01-01 13:04:38 -08: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
Arniu Tseng
cbd4f4472e
docs: update CHANGELOG.md ( #3336 )
2020-12-27 16:36:36 +01:00
Danilo Martins
2d9bea8d63
runtime: fix typo ( #3354 )
...
Co-authored-by: Danilo <vandor.danilo@gmail.com>
2020-12-27 16:17:00 +01:00
zhongjn
0048d43713
macros: improve select! error message ( #3352 )
...
Co-authored-by: Alice Ryhl <alice@ryhl.io>
2020-12-27 23:50:32 +09:00
Taiki Endo
770044caa7
chore: replace deprecated compare_and_swap with compare_exchange ( #3331 )
2020-12-27 10:44:21 +01:00
AJ Frantz
c4929264bc
examples: adjust buffering in examples ( #3328 )
2020-12-27 10:43:02 +01:00
Alice Ryhl
4d7b73f5b3
chore: create stream_ext module ( #3342 )
2020-12-26 17:05:51 +01:00
Alice Ryhl
2330edc875
chore: prepare tokio 1.0.1 release ( #3347 )
2020-12-25 22:20:05 +01:00
Alice Ryhl
fe2664a4e1
sync: remove RwLockWriteGuard::map and RwLockWriteGuard::try_map ( #3345 )
2020-12-25 21:36:48 +01:00
Laurențiu Nicola
1eefbc250a
docs: remove stream feature from docs ( #3335 )
2020-12-24 23:17:18 +09:00
Carl Lerche
a66017f049
chore: prepare Tokio 1.0 release ( #3319 )
2020-12-23 09:26:14 -08:00
Paolo Barbolini
aa6597ba66
compat: update traits naming to match tokio 1.0 ( #3324 )
2020-12-23 09:15:56 -08:00
Taiki Endo
ce0e9c67cf
chore: Revert "use #[non_exhaustive] instead of private unit field" ( #3323 )
...
This reverts commit 575938d4579e6fe6a89b700aadb0ae2bbab5483b.
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
Carl Lerche
0deaeb8494
chore: remove unused slab dependency ( #3318 )
2020-12-22 21:56:22 -08:00
Luke Steensen
a8dda19da4
chore: update to released bytes 1.0 ( #3317 )
2020-12-22 17:09:26 -08:00
Sean McArthur
be9fdb697d
time: make Interval::poll_tick() public ( #3316 )
2020-12-22 12:31:14 -08:00
Carl Lerche
2ee9520d10
fs: misc small API tweaks ( #3315 )
2020-12-22 11:13:41 -08:00
Carlos B
7d28e4cdbb
examples: add futures executor threadpool ( #3198 )
2020-12-22 20:08:43 +01:00
Alice Ryhl
0b83b3b8cc
fs,sync: expose poll_ fns on misc types ( #3308 )
...
Includes methods on:
* fs::DirEntry
* io::Lines
* io::Split
* sync::mpsc::Receiver
* sync::misc::UnboundedReceiver
2020-12-22 09:28:14 -08:00
Alice Ryhl
f95ad18980
net: clarify when wakeups are sent ( #3310 )
2020-12-22 07:38:14 -08:00
Taiki Endo
eee3ca65d6
deps: update rand to 0.8, loom to 0.4 ( #3307 )
2020-12-22 10:28:35 +01:00
Alice Ryhl
564c943309
io: rename AsyncFd::with_io() and rm with_poll() ( #3306 )
2020-12-21 15:42:38 -08:00
Bhargav
c7671a0384
io: add _mut variants of methods on AsyncFd ( #3304 )
...
Co-authored-by: Alice Ryhl <alice@ryhl.io>
2020-12-21 22:51:28 +01:00
Carl Lerche
2893359988
chore: update to bytes 1.0 git branch ( #3301 )
...
Updates the code base to track the `bytes` git branch. This is in
preparation for the 1.0 release.
Closes #3058
2020-12-19 15:57:16 -08:00
Carl Lerche
5e5f513542
chore: remove some left over stream feature code ( #3300 )
...
Removes the `stream` feature flag from `Cargo.toml` and removes the
`futures-core` dependency. Once `Stream` lands in `std`, a feature flag
is most likely not needed.
2020-12-19 14:15:00 -08:00
Arve Knudsen
1b70507894
net: remove {Tcp,Unix}Stream::shutdown() ( #3298 )
...
`shutdown()` on `AsyncWrite` performs a TCP shutdown. This avoids method
conflicts.
Closes #3294
2020-12-19 12:17:52 -08:00
Alice Ryhl
78f2340d25
tokio: remove prelude ( #3299 )
...
Closes : #3257
2020-12-19 11:42:24 -08:00
Florian Hübsch
e41e6cddbb
docs: tokio::main macro is also supported on rt ( #3243 )
...
Fixes : #3144
Refs: #2225
2020-12-19 19:12:08 +01:00
Lucio Franco
b99b00eb30
rt: change max_threads to max_blocking_threads ( #3287 )
...
Fixes #2802
2020-12-19 08:04:04 -08:00
Alice Ryhl
d948ccedfc
chore: fix stress test ( #3297 )
2020-12-19 12:11:10 +01:00
Alice Ryhl
3ecaf9fd9a
codec: write documentation for codec ( #3283 )
...
Co-authored-by: Lucio Franco <luciofranco14@gmail.com>
2020-12-18 21:32:27 +01:00
Carl Lerche
abd4c00255
time: enforce current_thread rt for time::pause ( #3289 )
...
Pausing time is a capability added to assist with testing Tokio code
dependent on time. Currently, the capability implicitly requires the
current_thread runtime.
This change enforces the requirement by panicking if called from a
multi-threaded runtime.
2020-12-17 15:37:08 -08:00
Lucio Franco
c5861ef62f
docs: Add more comprehensive stream docs ( #3286 )
...
* docs: Add more comprehensive stream docs
* Apply suggestions from code review
Co-authored-by: Alice Ryhl <alice@ryhl.io>
* Fix doc tests
Co-authored-by: Alice Ryhl <alice@ryhl.io>
2020-12-17 11:46:09 -05:00
Lucio Franco
59e4b35f49
stream: Fix a few doc issues ( #3285 )
2020-12-17 10:35:49 -05:00
Carl Lerche
d74d17307d
time: remove Box from Sleep ( #3278 )
...
Removes the box from `Sleep`, taking advantage of intrusive wakers. The
`Sleep` future is now `!Unpin`.
Closes #3267
2020-12-16 21:51:34 -08: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
Zahari Dichev
fcce78b33a
sync: add Semaphore::close ( #3065 )
...
## Motivation
The need to expose `Semaphore::close` as explained in #3061 .
## Solution
Expose `Semaphore::close`
Signed-off-by: Zahari Dichev <zaharidichev@gmail.com>
2020-12-15 10:22:45 -08:00
Carl Lerche
79d25b0a48
tracing: switch to unstable for 1.0. ( #3266 )
...
Enabling `tracing` integration now requires compiling with `--cfg
tokio_unstable`. Once `tracing-core` guarantees the same level of
stability as Tokio 1.0, unstable can be removed.
Closes #3258
2020-12-14 17:22:31 -08:00
Carl Lerche
3f29212cb7
fs: use cfgs on fns instead of OS ext traits ( #3264 )
...
Instead of using OS specific extension traits, OS specific methods are
moved onto the structs themselves and guarded with `cfg`. The API
documentation should highlight the function is platform specific.
Closes #2925
2020-12-14 09:29:10 -08:00
Joshua Nelson
48961fac89
Document SinkExt and other futures traits on docs.rs ( #3271 )
...
These are extremely hard to find if you don't already know they exist.
2020-12-14 10:28:36 -05:00
Carl Lerche
a7833e3007
sync: remove try_recv() from mpsc types ( #3263 )
...
The mpsc `try_recv()` functions have an issue where a sent message
happens-before a call to `try_recv()` but `try_recv()` returns `None`.
Fixing this is non-trivial, so the function is removed for 1.0. When the
bug is fixed, the function can be added back.
Closes #2020
2020-12-13 21:39:51 -08:00
Jacob O'Toole
1f862d2e95
sync: add watch::Sender::borrow() ( #3269 )
2020-12-13 20:46:11 -08:00
