Sha256: c048dc8d334de6896e6093cf3ce03ad01df08a6f1419979dbcd3b2d0e7180be4
Contents?: true
Size: 1.95 KB
Versions: 8
Compression:
Stored size: 1.95 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
# assert_equal :runnable, p.state
# 3.times { snooze }
# assert_equal :dead, 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
8 entries across 8 versions & 1 rubygems