def _remove_pending_deliveries(self, consumer_tag):
        remaining_events = deque()
        unprocessed_messages = []
        while self._pending_events:
            evt = self._pending_events.popleft()
            if type(evt) is _ConsumerDeliveryEvt:
                if evt.method.consumer_tag == consumer_tag:
                    unprocessed_messages.append(evt)
                    continue
            if type(evt) is _ConsumerCancellationEvt:
                if evt.method_frame.method.consumer_tag == consumer_tag:
                    # A broker-initiated Basic.Cancel must have arrived
                    # before our cancel request completed
                    continue

            remaining_events.append(evt)

        self._pending_events = remaining_events

        return unprocessed_messages
Returns the list of the members of the set that have scores
dataset/ETHPy150Open pika/pika/pika/adapters/blocking_connection.py/BlockingChannel._remove_pending_deliveries--crossover with--dataset/ETHPy150Open iamteem/redisco/redisco/containers.py/SortedSet.eq