diff options
| author | Samuel Williams <samuel.williams@oriontransfer.co.nz> | 2022-10-15 19:59:04 +1300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-10-15 19:59:04 +1300 |
| commit | 8a420670a29a7c78c7201f678eb26528621bf39f (patch) | |
| tree | 817a970087e36934979a4c9d4747f310b6224e42 /test/fiber/scheduler.rb | |
| parent | 1acc1a5c6d5d01b2822d7aa4356208095481724b (diff) | |
Introduce `Fiber::Scheduler#io_select` hook for non-blocking `IO.select`. (#6559)
Notes
Notes:
Merged-By: ioquatix <samuel@codeotaku.com>
Diffstat (limited to 'test/fiber/scheduler.rb')
| -rw-r--r-- | test/fiber/scheduler.rb | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/test/fiber/scheduler.rb b/test/fiber/scheduler.rb index 322564fe6d..3fd41ef6f1 100644 --- a/test/fiber/scheduler.rb +++ b/test/fiber/scheduler.rb @@ -197,6 +197,13 @@ class Scheduler @writable.delete(io) end + def io_select(...) + # Emulate the operation using a non-blocking thread: + Thread.new do + IO.select(...) + end.value + end + # Used for Kernel#sleep and Thread::Mutex#sleep def kernel_sleep(duration = nil) # $stderr.puts [__method__, duration, Fiber.current].inspect |