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.on_exception { |e| raise e }
    @zk.rm_rf(@base_path)
  end

  after do
    if @zk.closed?
      ZK.open(@connection_string) { |z| z.rm_rf(@base_path) }
    else
      @zk.rm_rf(@base_path)
      @zk.close!
      wait_until(2) { @zk.closed? }
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
zk-1.0.0	spec/shared/client_contexts.rb
zk-1.0.0.rc.1	spec/shared/client_contexts.rb