Contents

shared_context 'connection opts' do
  let(:connection_opts) { { :thread => :per_callback, :timeout => 5 } }
  let(:connection_host) { "#{ZK.default_host}:#{ZK.test_port}" }
  let(:connection_args) { [connection_host, connection_opts] }
end

shared_context 'threaded client connection' do
  include_context 'connection opts'

  before do
    @connection_string = "localhost:#{ZK.test_port}"
    @base_path = '/zktests'
    @zk = ZK::Client::Threaded.new(*connection_args).tap { |z| wait_until { z.connected? } }
    @threadpool_exception = nil
    @zk.on_exception { |e| @threadpool_exception = e }
    @zk.rm_rf(@base_path)
  end

  after do
#     raise @threadpool_exception if @threadpool_exception
    @zk.reopen if @zk.closed?
    wait_until(5) { @zk.connected? }
    
    @zk.rm_rf(@base_path)
    @zk.close!
    wait_until(5) { @zk.closed? }
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
zk-1.4.2	spec/shared/client_contexts.rb
zk-1.4.1	spec/shared/client_contexts.rb
zk-1.4.0	spec/shared/client_contexts.rb