Contents

shared_context 'threaded client connection' do
  before do
    @connection_string = "localhost:#{ZK_TEST_PORT}"
    @base_path = '/zktests'
    @zk = ZK::Client::Threaded.new(@connection_string).tap { |z| wait_until { z.connected? } }
    @zk.rm_rf(@base_path)
  end

  after do
    @zk.rm_rf(@base_path)
    @zk.close!

    wait_until(2) { @zk.closed? }
  end
end

shared_context 'multiplexed client connection' do
  before do
    @connection_string = "localhost:#{ZK_TEST_PORT}"
    @base_path = '/zktests'
    @zk = ZK::Client::Multiplexed.new(@connection_string).tap { |z| wait_until { z.connected? } }
    @zk.rm_rf(@base_path)
  end

  after do
    @zk.rm_rf(@base_path)
    @zk.close!

    wait_until(2) { @zk.closed? }
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
zk-0.9.1	spec/shared/client_contexts.rb