Fix timeout calculation in scheduler

kinnay · Mar 3, 2022 · d952763 · d952763
1 parent cdf9449
commit d952763
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/anynet/scheduler.py b/anynet/scheduler.py
@@ -25,7 +25,6 @@ async def process(self):
 				self.event = anyio.Event()
 
 	def process_timers(self):
-		minimum = None
 		current = time.monotonic()
 		items = self.events.copy().items()
 		for handle, (deadline, repeat, function, args) in items:
@@ -34,10 +33,9 @@ def process_timers(self):
 				if repeat is not None:
 					self.events[handle] = (deadline + repeat, repeat, function, args)
 				self.group.start_soon(function, *args)
-			else:
-				if minimum is None or minimum > deadline - current:
-					minimum = deadline - current
-		return minimum
+
+		timeouts = [event[0] - current for event in self.events.values()]
+		return min(timeouts, default=None)
 
 	def schedule(self, function, delay, *args):
 		deadline = time.monotonic() + delay

diff --git a/setup.py b/setup.py
@@ -8,7 +8,7 @@
 
 setuptools.setup(
 	name = "anynet",
-	version = "0.0.12",
+	version = "0.0.13",
 	description = "Networking library based on anyio",
 	long_description = long_description,
 	author = "Yannik Marchand",