Skip to main content

drain_incoming_data

Function drain_incoming_data 

Source
async fn drain_incoming_data<S: Stream + Unpin>(reader: S)
Expand description

Drains a HoprSocket reader, discarding all packets and logging throughput every ~60 seconds. Runs until the stream ends (sender side dropped).