Sha256: 6d88db5668eef5aa52ff2fce3dca948d19db799f26956b638f63c4c0653970d4
Contents?: true
Size: 1.66 KB
Versions: 24
Compression:
Stored size: 1.66 KB
Contents
require 'spec_helper'
describe ZK::ThreadedCallback do
before do
@called = []
@called.extend(MonitorMixin)
@cond = @called.new_cond
@callback = proc do |*a|
@called.synchronize do
@called << a
@cond.broadcast
end
end
@tcb = ZK::ThreadedCallback.new(@callback)
end
after do
@tcb.shutdown.should be_true
end
it %[should have started the thread] do
@tcb.should be_alive
end
describe %[pausing for fork] do
describe %[when running] do
before do
@tcb.pause_before_fork_in_parent
end
it %[should stop the thread] do
@tcb.should_not be_alive
end
it %[should allow calls] do
lambda { @tcb.call(:a) }.should_not raise_error
end
end
describe %[when not running] do
it %[should barf with InvalidStateError] do
@tcb.shutdown.should be_true
@tcb.should_not be_alive
lambda { @tcb.pause_before_fork_in_parent }.should raise_error(ZK::Exceptions::InvalidStateError)
end
end
end
describe %[resuming] do
describe %[after pause] do
before do
@tcb.pause_before_fork_in_parent
@tcb.should_not be_alive
end
it %[should deliver any calls on resume] do
@tcb.call(:a)
@tcb.call(:b)
@tcb.resume_after_fork_in_parent
start = Time.now
wait_until { @called.length >= 2 }
@called.length.should >= 2
end
end
describe %[if not paused] do
it %[should barf with InvalidStateError] do
lambda { @tcb.resume_after_fork_in_parent }.should raise_error(ZK::Exceptions::InvalidStateError)
end
end
end
end
Version data entries
24 entries across 24 versions & 1 rubygems