Does StreamExt::peek satisfy the broker liveness detection when using the StreamConsumer

[theelderbeever]

I am trying to improve the reliability of consumers being disconnected from the brokers due to occasional processing delays. It isn't always the case that I want to actually receive messages that I am not ready for but would likely to be able to inform the broker that the consumer is still alive. Does .peek on the stream have the same affect as polling the stream as far as the liveness detection is concerned? Does peeking the same message ref over and over satisfy it? Or do I need to actually consume messages via .next or .recv?