Sha256: 388ac4443784ccb5af9460e1308009c2be6e53f4fe511dc36fa2f7757cec3788

Contents?: true

Size: 786 Bytes

Versions: 4

Compression:

Stored size: 786 Bytes

Contents

require 'spec_helper'

module Cellect::Client
  describe NodeSet do
    it_behaves_like 'node set'
    let(:node_set){ Cellect::Client.node_set }

    #@note: node_set.nodes has state from intial code loading
    # the above def which is really a cached celluloid actor from boot
    # see Cellect::Client / Cellect::Server
    it 'should update the node list when changing' do
      begin
        pass_until_state_of node_set, is: :ready
        node_set.zk.create '/nodes/node', data: 'foo', mode: :ephemeral_sequential
        100.times do |i|
          break if node_set.nodes['node0000000001']
          Thread.pass
        end
        expect(node_set.nodes['node0000000001']).to eq 'foo'
      ensure
        node_set.zk.delete '/nodes/node0000000001'
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
cellect-client-1.3.3 spec/client/node_set_spec.rb
cellect-client-1.3.2 spec/client/node_set_spec.rb
cellect-client-1.3.1 spec/client/node_set_spec.rb
cellect-client-1.3.0 spec/client/node_set_spec.rb