def _on_consumer_generator_event(self, evt):
        self._queue_consumer_generator.pending_events.append(evt)
        # Schedule termination of connection.process_data_events using a
        # negative channel number
        self.connection._request_channel_dispatch(-self.channel_number)
Sink for the queue consumer generator's consumer events; append the
dataset/ETHPy150Open pika/pika/pika/adapters/blocking_connection.py/BlockingChannel._on_consumer_generator_event