1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61
|
class TestThreadedResource < Test::Unit::TestCase
def object
@object ||= {}
end
def resource
@resource = EM::ThreadedResource.new do
object
end
end
def teardown
resource.shutdown
end
def est_dispatch_completion
EM.run do
EM.add_timer(3) do
EM.stop
fail 'Resource dispatch timed out'
end
completion = resource.dispatch do |o|
o[:foo] = :bar
:foo
end
completion.callback do |result|
assert_equal :foo, result
EM.stop
end
completion.errback do |error|
EM.stop
fail "Unexpected error: #{error.message}"
end
end
assert_equal :bar, object[:foo]
end
def test_dispatch_failure
completion = resource.dispatch do |o|
raise 'boom'
end
completion.errback do |error|
assert_kind_of RuntimeError, error
assert_equal 'boom', error.message
end
end
def test_dispatch_threading
main = Thread.current
resource.dispatch do |o|
o[:dispatch_thread] = Thread.current
end
assert_not_equal main, object[:dispatch_thread]
end
def test_shutdown
# This test should get improved sometime. The method returning thread is
# NOT an api that will be maintained.
assert !resource.shutdown.alive?
end
end
|