pub fn queue_len(&self) -> u64 {
        let dequeued_messages = self.dequeued_outgoing_messages();
        let enqueued_messages = self.enqueued_outgoing_messages();
        enqueued_messages.saturating_sub(dequeued_messages)
    }
/// Returns the number of messages in the transmit queue of the channel.
///
/// PromQL: `fibers_rpc_channel_enqueued_outgoing_messages_total - fibers_rpc_channel_dequeued_outgoing_messages_total`
Returns the number of messages in the transmit queue of the channel.
Returns the number of messages in the transmit queue of the channel .
pub fn queue_len(&self) -> u64 {
        let dequeued_messages = self.dequeued_outgoing_messages();
        let enqueued_messages = self.enqueued_outgoing_messages();
        enqueued_messages.saturating_sub(dequeued_messages)
    }
pub fn queue_len ( & self ) -> u64 { let dequeued_messages = self . dequeued_outgoing_messages ( ) ; let enqueued_messages = self . enqueued_outgoing_messages ( ) ; enqueued_messages . saturating_sub ( dequeued_messages ) }
Returns the number of messages in the transmit queue of the channel.
Returns the number of messages in the transmit queue of the channel .
&self
&self