Troplo/PlexKodiConnect
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fix function arguments

Browse source
This commit is contained in:
croneter 2020-12-27 16:15:29 +01:00
parent 5e4cfdef52
commit b4a7a9ec41
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
resources/lib/backgroundthread.py
View file

@ -253,15 +253,15 @@ class OrderedQueue(queue.PriorityQueue, object):
self.next_index = 0 self.next_index = 0
super(OrderedQueue, self).__init__(maxsize) super(OrderedQueue, self).__init__(maxsize)
def _qsize(self, len=len): def _qsize(self):
try: try:
return len(self.queue) if self.queue[0][0] == self.next_index else 0 return len(self.queue) if self.queue[0][0] == self.next_index else 0
except IndexError: except IndexError:
return 0 return 0
def _get(self, heappop=heapq.heappop): def _get(self):
self.next_index += 1 self.next_index += 1
return heappop(self.queue) return heapq.heappop(self.queue)
class Tasks(list): class Tasks(list):
@ -335,9 +335,9 @@ class FunctionAsTask(Task):
class MutablePriorityQueue(queue.PriorityQueue): class MutablePriorityQueue(queue.PriorityQueue):
def _get(self, heappop=heapq.heappop): def _get(self):
self.queue.sort() self.queue.sort()
return heappop(self.queue) return heapq.heappop(self.queue)
def lowest(self): def lowest(self):
"""Return the lowest priority item in the queue (not reliable!).""" """Return the lowest priority item in the queue (not reliable!)."""