We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 378769a commit 8e328cfCopy full SHA for 8e328cf
spec/async/scheduler_spec.rb
@@ -23,7 +23,7 @@
23
require 'async/barrier'
24
require 'net/http'
25
26
-RSpec.describe Async::Scheduler do
+RSpec.describe Async::Scheduler do
27
describe 'Fiber.schedule' do
28
it "can start child task" do
29
fiber = nil
@@ -56,4 +56,22 @@
56
expect(sequence).to be == [:running]
57
end
58
59
+
60
+ describe '#run_once' do
61
+ it "can run the scheduler with a specific timeout" do
62
+ scheduler = Async::Scheduler.new
63
+ Fiber.set_scheduler(scheduler)
64
65
+ task = scheduler.async do |task|
66
+ sleep 1
67
+ end
68
69
+ duration = Async::Clock.measure do
70
+ scheduler.run_once(0.001)
71
72
73
+ expect(task).to be_running
74
+ expect(duration).to be <= 0.01
75
76
77
0 commit comments