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)
Create a new Line perpendicular to this linear entity which passes
dataset/ETHPy150Open pika/pika/pika/adapters/blocking_connection.py/BlockingChannel._on_consumer_generator_event--crossover with--dataset/ETHPy150Open sympy/sympy/sympy/geometry/line.py/LinearEntity.perpendicular_line