Update futures-preview to 0.3.0-alpha.19

staging
Taiki Endo 5 years ago
parent 155256cfd6
commit f0bf66d0df

@ -30,8 +30,8 @@ async-task = "1.0.0"
cfg-if = "0.1.9" cfg-if = "0.1.9"
crossbeam-channel = "0.3.9" crossbeam-channel = "0.3.9"
crossbeam-deque = "0.7.1" crossbeam-deque = "0.7.1"
futures-core-preview = "=0.3.0-alpha.18" futures-core-preview = "=0.3.0-alpha.19"
futures-io-preview = "=0.3.0-alpha.18" futures-io-preview = "=0.3.0-alpha.19"
futures-timer = "0.4.0" futures-timer = "0.4.0"
lazy_static = "1.4.0" lazy_static = "1.4.0"
log = { version = "0.4.8", features = ["kv_unstable"] } log = { version = "0.4.8", features = ["kv_unstable"] }
@ -48,11 +48,11 @@ broadcaster = { version = "0.2.6", optional = true, default-features = false, fe
femme = "1.2.0" femme = "1.2.0"
surf = "1.0.2" surf = "1.0.2"
tempdir = "0.3.7" tempdir = "0.3.7"
futures-preview = { version = "=0.3.0-alpha.19", features = ["async-await"] }
# These are used by the book for examples # These are used by the book for examples
futures-channel-preview = "=0.3.0-alpha.18" futures-channel-preview = "=0.3.0-alpha.19"
futures-util-preview = "=0.3.0-alpha.18" futures-util-preview = "=0.3.0-alpha.19"
[dev-dependencies.futures-preview] [patch.crates-io]
version = "=0.3.0-alpha.18" surf = { git = "https://github.com/taiki-e/surf", branch = "futures" }
features = ["std", "nightly", "async-await"]

@ -50,6 +50,6 @@ Add the following lines to `Cargo.toml`:
```toml ```toml
[dependencies] [dependencies]
futures-preview = { version = "0.3.0-alpha.18", features = [ "async-await", "nightly" ] } futures-preview = { version = "0.3.0-alpha.19", features = [ "async-await" ] }
async-std = "0.99" async-std = "0.99"
``` ```

@ -461,6 +461,15 @@ extension_trait! {
} }
} }
/// Initializes a buffer if necessary.
///
/// Currently, a buffer is always initialized because `read_initializer`
/// feature is not stable.
#[inline]
unsafe fn initialize<R: futures_io::AsyncRead>(_reader: &R, buf: &mut [u8]) {
std::ptr::write_bytes(buf.as_mut_ptr(), 0, buf.len())
}
#[cfg(test)] #[cfg(test)]
mod tests { mod tests {
use crate::io; use crate::io;

@ -64,7 +64,7 @@ pub fn read_to_end_internal<R: Read + ?Sized>(
g.buf.reserve(32); g.buf.reserve(32);
let capacity = g.buf.capacity(); let capacity = g.buf.capacity();
g.buf.set_len(capacity); g.buf.set_len(capacity);
rd.initializer().initialize(&mut g.buf[g.len..]); super::initialize(&rd, &mut g.buf[g.len..]);
} }
} }

Loading…
Cancel
Save