(self, lst)
| 54 | return heapq.heappop(self.lst) |
| 55 | |
| 56 | def extend(self, lst): |
| 57 | if self.lst: |
| 58 | for x in lst: |
| 59 | self.append(x) |
| 60 | else: |
| 61 | if isinstance(lst, list): |
| 62 | self.lst = lst |
| 63 | heapq.heapify(lst) |
| 64 | else: |
| 65 | self.lst = lst.lst |
| 66 | |
| 67 | |
| 68 | class Consumer(Utils.threading.Thread): |
no test coverage detected