Better handling of internal timeout in io_wait.

socketry · Aug 25, 2023 · 723d2a2 · 723d2a2
1 parent bc9deca
commit 723d2a2
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/lib/async/scheduler.rb b/lib/async/scheduler.rb
@@ -171,17 +171,11 @@ def io_wait(io, events, timeout = nil)
 
 			if timeout
 				timer = @timers.after(timeout) do
-					fiber.raise(TimeoutError)
+					fiber.transfer
 				end
 			end
 
-			# Console.logger.info(self, "-> io_wait", fiber, io, events)
-			events = @selector.io_wait(fiber, io, events)
-			# Console.logger.info(self, "<- io_wait", fiber, io, events)
-
-			return events
-		rescue TimeoutError
-			return false
+			return @selector.io_wait(fiber, io, events)
 		ensure
 			timer&.cancel
 		end