// Send messages at certain rate and if no real traffic is available, send cover message.
Send messages at certain rate and if no real traffic is available, send cover message.
Send messages at certain rate and if no real traffic is available send cover message .
async fn run_normal_out_queue(&mut self) {
        // we should set initial delay only when we actually start the stream
        self.next_delay = Box::pin(time::sleep(sample_poisson_duration(
            &mut self.rng,
            self.config.average_message_sending_delay,
        )));
        while let Some(next_message) = self.next().await {
            self.on_message(next_message).await;
        }
    }
async fn run_normal_out_queue ( & mut self ) { // we should set initial delay only when we actually start the stream self . next_delay = Box :: pin ( time :: sleep ( sample_poisson_duration ( & mut self . rng , self . config . average_message_sending_delay , ) ) ) ; while let Some ( next_message ) = self . next ( ) . await { self . on_message ( next_message ) . await ; } }
Send messages at certain rate and if no real traffic is available, send cover message.
Send messages at certain rate and if no real traffic is available send cover message .
&mut self