All notable changes to async-std will be documented in this file.
The format is based on Keep a Changelog, and this project adheres to Semantic Versioning.
1.0.1 - 2019-11-12
We were seeing a regression in our fs performance, caused by too many long-running tasks. This patch fixes that regression by being more proactive about closing down idle threads.
- Improved thread startup/shutdown algorithm in
task::spawn_blocking. - Fixed a typo in the tutorial.
1.0.0 - 2019-11-11
This release marks the 1.0.0 release of async-std; a major milestone for our
development. This release itself mostly includes quality of life improvements
for all of modules, including more consistent API bounds for a lot of our
submodules.
The biggest change is that we're now using the full semver range,
major.minor.patch, and any breaking changes to our "stable" APIs will require
an update of the major number.
We're excited we've hit this milestone together with you all. Thank you!
- Added
Future::joinas "unstable", replacingfuture::join!. - Added
Future::try_joinas "unstable", replacingfuture::try_join!. - Enabled
stableandbetachannel testing on CI. - Implemented
FromIteratorandExtendforPathBuf. - Implemented
FromStreamforPathBuf. - Loosened the trait bounds of
io::copyon "unstable".
- Added a
Syncbound toRwLock, resolving a memory safety issue. - Fixed a bug in
Stream::take_whilewhere it could continue after it should've ended. - Fixed a bug where our
attributesCargo feature wasn't working as intended. - Improved documentation of
Stream::merge, documenting ordering guarantees. - Update doc imports in examples to prefer async-std's types.
- Various quality of life improvements to the
futuresubmodule. - Various quality of life improvements to the
pathsubmodule. - Various quality of life improvements to the
streamsubmodule.
- Removed
future::join!in favor ofFuture::join. - Removed
future::try_join!in favor ofFuture::try_join.
0.99.12 - 2019-11-07
This patch upgrades us to futures 0.3, support for async/await on Rust
Stable, performance improvements, and brand new module-level documentation.
- Added
Future::flattenas "unstable". - Added
Future::raceas "unstable" (replacesfuture::select!). - Added
Future::try_raceas "unstable" (replacesfuture::try_select!). - Added
Stderr::lockas "unstable". - Added
Stdin::lockas "unstable". - Added
Stdout::lockas "unstable". - Added
Stream::copiedas "unstable". - Added
Stream::eqas "unstable". - Added
Stream::max_by_keyas "unstable". - Added
Stream::minas "unstable". - Added
Stream::neas "unstable". - Added
Stream::positionas "unstable". - Added
StreamExtandFutureExtas enumerable in theprelude. - Added
TcpListenerandTcpStreamintegration tests. - Added
stream::from_iter. - Added
sync::WakerSetfor internal use. - Added an example to handle both
IP v4andIP v6connections. - Added the
defaultCargo feature. - Added the
attributesCargo feature. - Added the
stdCargo feature.
- Fixed a bug in the blocking threadpool where it didn't spawn more than one thread.
- Fixed a bug with
Stream::mergewhere sometimes it ended too soon. - Fixed a bug with our GitHub actions setup.
- Fixed an issue where our channels could spuriously deadlock.
- Refactored the
taskmodule. - Removed a deprecated GitHub action.
- Replaced
futures-previewwithfutures. - Replaced
lazy_staticwithonce_cell. - Replaced all uses of
VecDequeuein the examples withstream::from_iter. - Simplified
sync::RwLockusing the internalsync::WakerSettype. - Updated the
pathsubmodule documentation to match std. - Updated the mod-level documentation to match std.
- Removed
future::select!(replaced byFuture::race). - Removed
future::try_select!(replaced byFuture::try_race).
0.99.11 - 2019-10-29
This patch introduces async_std::sync::channel, a novel asynchronous port of
the ultra-fast Crossbeam channels. This has been one of the most anticipated
features for async-std, and we're excited to be providing a first version of
this!
In addition to channels, this patch has the regular list of new methods, types, and doc fixes.
Send and receive items from a channel
// Create a bounded channel with a max-size of 1
let (s, r) = channel(1);
// This call returns immediately because there is enough space in the channel.
s.send(1).await;
task::spawn(async move {
// This call blocks the current task because the channel is full.
// It will be able to complete only after the first message is received.
s.send(2).await;
});
// Receive items from the channel
task::sleep(Duration::from_secs(1)).await;
assert_eq!(r.recv().await, Some(1));
assert_eq!(r.recv().await, Some(2));- Added
Future::delayas "unstable" - Added
Stream::flat_mapas "unstable" - Added
Stream::flattenas "unstable" - Added
Stream::productas "unstable" - Added
Stream::sumas "unstable" - Added
Stream::min_by_key - Added
Stream::max_by - Added
Stream::timeoutas "unstable" - Added
sync::channelas "unstable". - Added doc links from instantiated structs to the methods that create them.
- Implemented
Extend+FromStreamforPathBuf.
- Fixed an issue with
block_onso it works even when nested. - Fixed issues with our Clippy check on CI.
- Replaced our uses of
cfg_ifwith our own macros, simplifying the codebase. - Updated the homepage link in
Cargo.tomlto point to async.rs. - Updated the module-level documentation for
streamandsync. - Various typos and grammar fixes.
- Removed redundant file flushes, improving the performance of
Fileoperations
Nothing was removed in this release.
0.99.10 - 2019-10-16
This patch stabilizes several core concurrency macros, introduces async versions
of Path and PathBuf, and adds almost 100 other commits.
Asynchronously read directories from the filesystem
use async_std::fs;
use async_std::path::Path;
use async_std::prelude::*;
let path = Path::new("/laputa");
let mut dir = fs::read_dir(&path).await.unwrap();
while let Some(entry) = dir.next().await {
if let Ok(entry) = entry {
println!("{:?}", entry.path());
}
}Cooperatively reschedule the current task on the executor
use async_std::prelude::*;
use async_std::task;
task::spawn(async {
let x = fibonnacci(1000); // Do expensive work
task::yield_now().await; // Allow other tasks to run
x + fibonnacci(100) // Do more work
})Create an interval stream
use async_std::prelude::*;
use async_std::stream;
use std::time::Duration;
let mut interval = stream::interval(Duration::from_secs(4));
while let Some(_) = interval.next().await {
println!("prints every four seconds");
}- Added
FutureExtto theprelude, allowing us to extendFuture - Added
Stream::cmp - Added
Stream::ge - Added
Stream::last - Added
Stream::le - Added
Stream::lt - Added
Stream::mergeas "unstable", replacingstream::join! - Added
Stream::partial_cmp - Added
Stream::take_while - Added
Stream::try_fold - Added
future::IntoFutureas "unstable" - Added
io::BufRead::split - Added
io::Write::write_fmt - Added
print!,println!,eprint!,eprintln!macros as "unstable" - Added
processas "unstable", re-exporting std types only for now - Added
std::netre-exports to thenetsubmodule - Added
std::path::PathBufwith all associated methods - Added
std::path::Pathwith all associated methods - Added
stream::ExactSizeStreamas "unstable" - Added
stream::FusedStreamas "unstable" - Added
stream::Product - Added
stream::Sum - Added
stream::from_fn - Added
stream::intervalas "unstable" - Added
stream::repeat_with - Added
task::spawn_blockingas "unstable", replacingtask::blocking - Added
task::yield_now - Added
write!andwriteln!macros as "unstable" - Stabilized
future::join!andfuture::try_join! - Stabilized
future::timeout - Stabilized
path - Stabilized
task::ready!
- Fixed
BufWriter::into_innerso it callsflushbefore yielding - Refactored
io::BufWriterinternals - Refactored
net::ToSocketAddrsinternals - Removed Travis CI entirely
- Rewrote the README.md
- Stabilized
io::Cursor - Switched bors over to use GitHub actions
- Updated the
iodocumentation to match std'siodocs - Updated the
taskdocumentation to match std'sthreaddocs
- Removed the "unstable"
stream::join!in favor ofStream::merge - Removed the "unstable"
task::blockingin favor oftask::spawn_blocking
0.99.9 - 2019-10-08
This patch upgrades our futures-rs version, allowing us to build on the 1.39
beta. Additionally we've introduced map and for_each to Stream. And we've
added about a dozen new FromStream implementations for std types, bringing
us up to par with std's FromIterator implementations.
And finally we've added a new "unstable" task::blocking function which can be
used to convert blocking code into async code using a threadpool. We've been
using this internally for a while now to async-std to power our fs and
net::SocketAddr implementations. With this patch userland code now finally has
access to this too.
Create a stream of tuples, and collect into a hashmap
let a = stream::once(1u8);
let b = stream::once(0u8);
let s = a.zip(b);
let map: HashMap<u8, u8> = s.collect().await;
assert_eq!(map.get(&1), Some(&0u8));Spawn a blocking task on a dedicated threadpool
task::blocking(async {
println!("long-running task here");
}).await;- Added
stream::Stream::map - Added
stream::Stream::for_each - Added
stream::Stream::try_for_each - Added
task::blockingas "unstable" - Added
FromStreamfor allstd::{option, collections, result, string, sync}types. - Added the
pathsubmodule as "unstable".
- Updated
futures-previewto0.3.0-alpha.19, allowing us to build onrustc 1.39.0-beta. - As a consequence of this upgrade, all of our concrete stream implementations
now make use of
Stream::size_hintto optimize internal allocations. - We now use GitHub Actions through actions-rs, in addition to Travis CI. We intend to fully switch in the near future.
- Fixed a bug introduced in 0.99.6 where Unix Domain Listeners would sometimes become unresponsive.
- Updated our
sync::Barrierdocs to match std. - Updated our
stream::FromStreamdocs to match std'sFromIterator.
0.99.8 - 2019-09-28
- Added README to examples directory.
- Added concurrency documentation to the futures submodule.
- Added
io::Read::takemethod. - Added
io::Read::by_refmethod. - Added
io::Read::chainmethod.
- Pin futures-preview to
0.3.0-alpha.18, to avoid rustc upgrade problems. - Simplified extension traits using a macro.
- Use the
broadcastmodule withstd::sync::Mutex, reducing dependencies.
0.99.7 - 2019-09-26
- Added
future::joinmacro as "unstable" - Added
future::selectmacro as "unstable" - Added
future::try_joinmacro as "unstable" - Added
future::try_selectmacro as "unstable" - Added
io::BufWriterstruct - Added
stream::Extendtrait - Added
stream::Stream::chainmethod - Added
stream::Stream::filtermethod - Added
stream::Stream::inspectmethod - Added
stream::Stream::skip_whilemethod - Added
stream::Stream::skipmethod - Added
stream::Stream::step_bymethod - Added
sync::Arcstruct from stdlib - Added
sync::Barrierstruct as "unstable" - Added
sync::Weakstruct from stdlib - Added
task::readymacro as "unstable"
- Correctly marked the
pinsubmodule as "unstable" in the docs - Updated tutorial to have certain functions suffixed with
_loop iotraits are now re-exports of futures-rs types, allowing them to be implementedstreamtraits are now re-exports of futures-rs types, allowing them to be implementedprelude::*now needs to be in scope for functionsioandstreamtraits to work
0.99.6 - 2019-09-19
- Added
stream::Stream::collectas "unstable" - Added
stream::Stream::enumerate - Added
stream::Stream::fuse - Added
stream::Stream::fold - Added
stream::Stream::scan - Added
stream::Stream::zip - Added
stream::joinmacro as "unstable" - Added
stream::DoubleEndedStreamas "unstable" - Added
stream::FromStreamtrait as "unstable" - Added
stream::IntoStreamtrait as "unstable" - Added
io::Cursoras "unstable" - Added
io::BufRead::consumemethod - Added
io::repeat - Added
io::Sliceandio::SliceMut - Added documentation for feature flags
- Added
pinsubmodule as "unstable" - Added the ability to
collecta stream ofResult<T, E>s into aResult<impl FromStream<T>, E>
- Refactored the scheduling algorithm of our executor to use work stealing
- Refactored the network driver, removing 400 lines of code
- Removed the
Sendbound fromtask::block_on - Removed
Unpinbound fromimpl<T: futures::stream::Stream> Stream for T
0.99.5 - 2019-09-12
- Added tests for
io::timeout - Added
io::BufRead::fill_buf, anasync fncounterpart topoll_fill_buf - Added
fs::create_dir_all - Added
future::timeout, a free function to time out futures after a threshold - Added
io::prelude - Added
net::ToSocketAddrs, a non-blocking version of std'sToSocketAddrs - Added
stream::Stream::all - Added
stream::Stream::filter_map - Added
stream::Stream::find_map - Added
stream::Stream::find - Added
stream::Stream::min_by - Added
stream::Stream::nth
- Polished the text and examples of the tutorial
cargo fmton all examples- Simplified internals of
TcpStream::connect_to - Modularized our CI setup, enabled a rustfmt fallback, and improved caching
- Reduced our dependency on the
futures-rscrate, improving compilation times - Split
io::Read,io::Write,io::BufRead, andstream::Streaminto multiple files fs::Filenow flushes more often to prevent flushes duringseek- Updated all dependencies
- Fixed a bug in the conversion of
Fileinto raw handle - Fixed compilation errors on the latest nightly
0.99.4 - 2019-08-21
- Many small changes in the book, mostly typos
- Documentation fixes correcting examples
- Now works with recent nightly with stabilised async/await (> 2019-08-21)
0.99.3 - 2019-08-16
- Initial beta release