Method _next_channel_number

pika/connection.py:1745–1758

Return the next available channel number or raise an exception. :rtype: int

(self)

        return isinstance(value, frame.ProtocolHeader)

    def _next_channel_number(self) -> int:
        """Return the next available channel number or raise an exception.

        :rtype: int

        """
        limit = self.params.channel_max or pika.channel.MAX_CHANNELS
        if len(self._channels) >= limit:
            raise exceptions.NoFreeChannels()

        for num in range(1, len(self._channels) + 1):
            if num not in self._channels:
                return num
        return len(self._channels) + 1

    def _on_channel_cleanup(self, channel: Channel) -> None:
        """Remove the channel from the dict of channels when Channel.CloseOk is