'Sink for the queue consumer generator\'s consumer events; append the
event to queue consumer generator\'s pending events buffer.
:param evt: an object of type _ConsumerDeliveryEvt or
_ConsumerCancellationEvt'

def _on_consumer_generator_event(self, evt):

    self._queue_consumer_generator.pending_events.append(evt)
    self.connection._request_channel_dispatch((- self.channel_number))
