Async::IO::CZTopSocket: speed up #wait_readable and #wait_writable

paddor · Jan 4, 2024 · 02c20b7 · 02c20b7
1 parent 710d86b
commit 02c20b7
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/cztop/async.rb b/lib/cztop/async.rb
@@ -49,6 +49,8 @@ def <<(...)
       def wait_readable(timeout = read_timeout)
         @io_fd ||= ::IO.for_fd @io.fd, autoclose: false
 
+        return true if @io.readable?
+
         if timeout
           timeout_at = now + timeout
 
@@ -67,6 +69,8 @@ def wait_readable(timeout = read_timeout)
       def wait_writable(timeout = write_timeout)
         @io_fd ||= ::IO.for_fd @io.fd, autoclose: false
 
+        return true if @io.writable?
+
         if timeout
           timeout_at = now + timeout