def remove_at(self, index):

        with self.lock:
            item = self.items.pop(index)[0]
            heapq.heapify(self.items)
        return item
Removes item at given index
dataset/ETHPy150Open ReactiveX/RxPY/rx/internal/priorityqueue.py/PriorityQueue.remove_at