def enqueue(self, item):

        with self.lock:
            heapq.heappush(self.items, (item, self.count))
            self.count += 1
Adds item to queue
dataset/ETHPy150Open ReactiveX/RxPY/rx/internal/priorityqueue.py/PriorityQueue.enqueue