Sha256: a89306a951061dd83bd6649920131bf4d86b83695909969444441121d5246811
Contents?: true
Size: 1.75 KB
Versions: 31
Compression:
Stored size: 1.75 KB
Contents
# frozen_string_literal: true
require_relative 'helper'
class SuperviseTest < MiniTest::Test
def test_supervise
p = spin { supervise }
snooze
f1 = p.spin { receive }
f2 = p.spin { receive }
snooze
assert_equal p.state, :waiting
f1 << 'foo'
f1.await
snooze
assert_equal :waiting, p.state
assert_equal :waiting, f2.state
f2 << 'bar'
f2.await
snooze
assert_equal :waiting, p.state
end
def test_supervise_with_restart
watcher = spin { receive }
parent = spin { supervise(restart: true, watcher: watcher) }
snooze
buffer = []
f1 = parent.spin do
buffer << 'f1'
end
f1.await
assert_equal ['f1'], buffer
watcher.await
assert_equal ['f1', 'f1'], buffer
end
def test_supervise_with_restart_on_error
parent = spin { supervise(restart: true) }
snooze
buffer = []
f1 = parent.spin do
buffer << 'f1'
buffer << receive
end
snooze
assert_equal ['f1'], buffer
f1.raise 'foo'
3.times { snooze }
assert_equal ['f1', 'f1'], buffer
assert_equal :dead, f1.state
# f1 should have been restarted by supervisor
f1 = parent.children.first
assert_kind_of Fiber, f1
f1 << 'foo'
f1.await
assert_equal ['f1', 'f1', 'foo'], buffer
end
def test_supervisor_termination
f = nil
p = spin do
f = spin { sleep 1 }
supervise
end
sleep 0.01
p.terminate
p.await
assert :dead, f.state
assert :dead, p.state
end
def test_supervisor_termination_with_restart
f = nil
p = spin do
f = spin { sleep 1 }
supervise(restart: true)
end
sleep 0.01
p.terminate
p.await
assert :dead, f.state
assert :dead, p.state
end
end
Version data entries
31 entries across 31 versions & 1 rubygems