[][src]Function pseudo_async_io::wrap_pair

pub fn wrap_pair<R: Read, W: Write>(r: R, w: W) -> PseudoAsyncIoPair<R, W>

Examples

#![feature(async_await, await_macro, futures_api)]
use std::io::Cursor;
use futures::{
    io::AsyncReadExt,
    io::AsyncWriteExt,
    future::FutureExt,
    executor::block_on,
};
use pseudo_async_io;
let mut rc = Cursor::new(vec![5, 4, 3, 2, 1, 0]);
let mut wc = Cursor::new(vec![0; 6]);
let mut w = pseudo_async_io::wrap_pair(rc, wc);
block_on(w.write_all(&[1, 2, 3]));
assert_eq!(w.writer.get_ref(), &[1, 2, 3, 0, 0, 0]);
let mut tmp = [0; 3];
block_on(w.read(&mut tmp));
assert_eq!(&tmp, &[5, 4, 3]);