mirror of https://github.com/fafhrd91/actix-net
codec: use tokio assert_ready macro (#788)
This commit is contained in:
parent
bdb56a838d
commit
c6ebc4e2b7
|
|
@ -23,26 +23,6 @@ macro_rules! bilateral {
|
||||||
}};
|
}};
|
||||||
}
|
}
|
||||||
|
|
||||||
macro_rules! assert_ready {
|
|
||||||
($e:expr) => {{
|
|
||||||
use core::task::Poll::*;
|
|
||||||
match $e {
|
|
||||||
Ready(v) => v,
|
|
||||||
Pending => panic!("pending"),
|
|
||||||
}
|
|
||||||
}};
|
|
||||||
($e:expr, $($msg:tt),+) => {{
|
|
||||||
use core::task::Poll::*;
|
|
||||||
match $e {
|
|
||||||
Ready(v) => v,
|
|
||||||
Pending => {
|
|
||||||
let msg = format_args!($($msg),+);
|
|
||||||
panic!("pending; {}", msg)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}};
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug)]
|
#[derive(Debug)]
|
||||||
pub struct Bilateral {
|
pub struct Bilateral {
|
||||||
pub calls: VecDeque<io::Result<Vec<u8>>>,
|
pub calls: VecDeque<io::Result<Vec<u8>>>,
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue