pub fn listen_for_connection_blocked(
        &mut self,
    ) -> Result<Receiver<ConnectionBlockedNotification>> {
        let (tx, rx) = crossbeam_channel::unbounded();
        self.channel0.set_blocked_tx(tx)?;
        Ok(rx)
    }
/// Open a crossbeam channel to receive [connection blocked
/// notifications](https://www.rabbitmq.com/connection-blocked.html) from the server.
///
/// There can be only one connection blocked listener. If you call this method a second (or
/// more) time, the I/O thread will drop the sending side of previously returned channels.
///
/// Dropping the `Receiver` returned by this method is harmless. If the I/O loop receives a
/// connection blocked notification and there is no listener registered or the
/// previously-registered listener has been dropped, it will discard the notification.
Open a crossbeam channel to receive [connection blocked
notifications] from the server.

There can be only one connection blocked listener. If you call this method a second (or
more) time, the I/O thread will drop the sending side of previously returned channels.

Dropping the `Receiver` returned by this method is harmless. If the I/O loop receives a
connection blocked notification and there is no listener registered or the
previously-registered listener has been dropped, it will discard the notification.
Open a crossbeam channel to receive [ connection blocked notifications ] from the server . There can be only one connection blocked listener . If you call this method a second ( or more ) time the I / O thread will drop the sending side of previously returned channels . Dropping the ` Receiver ` returned by this method is harmless . If the I / O loop receives a connection blocked notification and there is no listener registered or the previously - registered listener has been dropped it will discard the notification .
pub fn listen_for_connection_blocked(
        &mut self,
    ) -> Result<Receiver<ConnectionBlockedNotification>> {
        let (tx, rx) = crossbeam_channel::unbounded();
        self.channel0.set_blocked_tx(tx)?;
        Ok(rx)
    }
pub fn listen_for_connection_blocked ( & mut self , ) -> Result < Receiver < ConnectionBlockedNotification > > { let ( tx , rx ) = crossbeam_channel :: unbounded ( ) ; self . channel0 . set_blocked_tx ( tx ) ? ; Ok ( rx ) }
Open a crossbeam channel to receive [connection blocked
notifications](https://www.rabbitmq.com/connection-blocked.html) from the server.
Open a crossbeam channel to receive [ connection blocked notifications ] ( https : // www . rabbitmq . com / connection - blocked . html ) from the server .
&mut self
&mut self