[tokio-consumer] one message lag

[51yu]

when use tokio consumer, the message is always one record behind

let properties = ConnectionProperties::default().with_tokio_executor();
let conn = Connection::connect(&config.uri, properties).await?;
let channel = conn.create_channel().await?;
let consumer = channel
            .basic_consume(...);
for bytes in consumer.into_iter() {
}

lapin version: 1.7.1 tokio version: 1.6.1 tokio-amqp: 1.0.0

[Keruspe]

Does this happen without tokio?

[Keruspe]

Also, does it still happen with tokio-amqp 1.1.0?