pub async fn pause_consumer(&self, consumer_id: ConsumerId) -> Result<(), RequestError> {
        if let Some(consumer) = self.consumers.get(&consumer_id) {
            if !consumer.paused() {
                consumer.pause().await?;
            }
        } else {
            println!("WARN%: consumer not found");
        }
        Ok(())
    }
///
/// This function used to pause the stream of provided consumer id
///
This function used to pause the stream of provided consumer id
This function used to pause the stream of provided consumer id
pub async fn pause_consumer(&self, consumer_id: ConsumerId) -> Result<(), RequestError> {
        if let Some(consumer) = self.consumers.get(&consumer_id) {
            if !consumer.paused() {
                consumer.pause().await?;
            }
        } else {
            println!("WARN%: consumer not found");
        }
        Ok(())
    }
pub async fn pause_consumer ( & self , consumer_id : ConsumerId ) -> Result < ( ) , RequestError > { if let Some ( consumer ) = self . consumers . get ( & consumer_id ) { if ! consumer . paused ( ) { consumer . pause ( ) . await ? ; } } else { println ! ( " " ) ; } Ok ( ( ) ) }
This function used to pause the stream of provided consumer id
This function used to pause the stream of provided consumer id
&self
consumer_id
ConsumerId
&self
consumer_id
ConsumerId