! packets.is_empty() =>
{
while let Some(packet) = packets.pop_front() {
- match upbound.add(ic.max_batch_up, packet.into()/*xxx*/) {
- Err(packet) => { packets.push_front(packet.into()/*xxx*/); break; }
+ match upbound.add(ic.max_batch_up, packet.into()/*todo:504*/) {
+ Err(packet) => { packets.push_front(packet.into()/*todo:504*/); break; }
Ok(()) => { },
}
}
pub type Frame = Vec<u8>;
pub type FramesData = Vec<Vec<u8>>;
-//pub type Frame = Box<[u8]>;
-//pub type FramesData = Vec<Frame>;
-// `From<Box<[u8]>>` is not implemented for `Bytes`
+// todo: https://github.com/tokio-rs/bytes/pull/504
+// pub type Frame = Box<[u8]>;
+// pub type FramesData = Vec<Frame>;
+// `From<Box<[u8]>>` is not implemented for `Bytes`
+// when this is fixed, there are two `into`s in client.rs which
+// become redundant (search for todo:504)
#[derive(Default)]