def dequeue(self):

        with self.lock:
            item = heapq.heappop(self.items)[0]
        return item
Returns and removes item with lowest priority from queue
dataset/ETHPy150Open ReactiveX/RxPY/rx/internal/priorityqueue.py/PriorityQueue.dequeue