Sha256: 135767a083858f8c4ed6f32745a17e137f7dd78ea3acd350c907848a13a50a65
Contents?: true
Size: 700 Bytes
Versions: 1
Compression:
Stored size: 700 Bytes
Contents
# frozen_string_literal: true require_relative 'helper' class AsyncTest < MiniTest::Test def test_that_async_watcher_receives_signal_across_threads count = 0 a = Gyro::Async.new spin { a.await count += 1 } snooze Thread.new do orig_sleep 0.001 a.signal end suspend assert_equal 1, count end def test_that_async_watcher_coalesces_signals count = 0 a = Gyro::Async.new coproc = spin { loop { a.await count += 1 spin { coproc.stop } } } snooze Thread.new do orig_sleep 0.001 3.times { a.signal } end coproc.await assert_equal 1, count end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
polyphony-0.40 | test/test_async.rb |