tokio - Contrib clone of tokio

Age	Commit message (Collapse)	Author
2020-12-12	sync: add blocking_recv method to UnboundedReceiver, similar to ↵HEAD master	Sunjay Varma
	Receiver::blocking_recv (#3262)
2020-10-12	sync: change chan `closed(&mut self)` to `closed(&self)` (#2939)	Zahari Dichev

2020-09-28	sync: Add `is_closed` method to mpsc senders (#2726)	Mikail Bagishov
	Co-authored-by: Alice Ryhl <alice@ryhl.io>
2020-09-25	sync: add `mpsc::Sender::closed` future (#2840)	Zahari Dichev
	Adding closed future, makes it possible to select over closed and some other work, so that the task is woken when the channel is closed and can proactively cancel itself. Added a mpsc::Sender::closed future that will become ready when the receiver is closed.
2020-09-24	sync: support mpsc send with `&self` (#2861)	Carl Lerche
	Updates the mpsc channel to use the intrusive waker based sempahore. This enables using `Sender` with `&self`. Instead of using `Sender::poll_ready` to ensure capacity and updating the `Sender` state, `async fn Sender::reserve()` is added. This function returns a `Permit` value representing the reserved capacity. Fixes: #2637 Refs: #2718 (intrusive waiters)
2020-09-09	sync: document mpsc::bounded minimum buffer size (#2808)	Zephyr Shannon

2020-06-17	sync: documentation for mpsc channels (#2600)	Alice Ryhl

2020-04-04	doc: add error explanation for UnboundedSender::send() (#2372)	Vojtech Kral

2020-01-24	docs: use third form in API docs (#2027)	Oleg Nosov

2019-12-22	doc: fill out `fs` and remove html links (#2015)	Carl Lerche
	also add an async version of `fs::canonicalize`
2019-12-18	stream: add `next` and `map` utility fn (#1962)	Artem Vorotnikov
	Introduces `StreamExt` trait. This trait will be used to add utility functions to make working with streams easier. This patch includes two functions: * `next`: a future returning the item in the stream. * `map`: transform each item in the stream.
2019-12-10	Add Mutex::try_lock and (Unbounded)Receiver::try_recv (#1939)	Michael P. Jung

2019-11-15	Limit `futures` dependency to `Stream` via feature flag (#1774)	Carl Lerche
	In an effort to reach API stability, the `tokio` crate is shedding its _public_ dependencies on crates that are either a) do not provide a stable (1.0+) release with longevity guarantees or b) match the `tokio` release cadence. Of course, implementing `std` traits fits the requirements. The on exception, for now, is the `Stream` trait found in `futures_core`. It is expected that this trait will not change much and be moved into `std. Since Tokio is not yet going reaching 1.0, I feel that it is acceptable to maintain a dependency on this trait given how foundational it is. Since the `Stream` implementation is optional, types that are logically streams provide `async fn next_*` functions to obtain the next value. Avoiding the `next()` name prevents fn conflicts with `StreamExt::next()`. Additionally, some misc cleanup is also done: - `tokio::io::io` -> `tokio::io::util`. - `delay` -> `delay_until`. - `Timeout::new` -> `timeout(...)`. - `signal::ctrl_c()` returns a future instead of a stream. - `{tcp,unix}::Incoming` is removed (due to lack of `Stream` trait). - `time::Throttle` is removed (due to lack of `Stream` trait). - Fix: `mpsc::UnboundedSender::send(&self)` (no more conflict with `Sink` fns).
2019-11-04	chore: unify all mocked `loom` files (#1732)	Carl Lerche
	When the crates were merged, each component kept its own `loom` file containing mocked types it needed. This patch unifies them all in one location.
2019-10-29	sync: move into `tokio` crate (#1705)	Carl Lerche
	A step towards collapsing Tokio sub crates into a single `tokio` crate (#1318). The sync implementation is now provided by the main `tokio` crate. Functionality can be opted out of by using the various net related feature flags.