Contents

require File.expand_path 'test_helper', File.dirname(__FILE__)

class TestClientDisconnect < MiniTest::Test

  def test_client_disconnect
    ts_name = "ts_#{Time.now.to_i}_#{Time.now.usec}"
    _tuple1 = nil
    _tuple2 = nil
    _tuple3 = nil
    _tuple4 = nil

    EM::run do
      client1 = EM::RocketIO::Linda::Client.new App.url

      client1.io.on :connect do
        client2 = EM::RocketIO::Linda::Client.new App.url
        client2.io.on :connect do
          ts1 = client1.tuplespace[ts_name]
          ts2 = client2.tuplespace[ts_name]
          ts1.read [1,2] do |tuple|
            _tuple1 = tuple
          end
          ts1.take [1,2] do |tuple|
            _tuple2 = tuple
          end
          ts1.watch [1,2] do |tuple|
            _tuple3 = tuple
          end
          ts2.take [1,2] do |tuple|
            _tuple4 = tuple
          end
          client1.io.close
          sleep 3
          ts2.write [1,2,3]
          ts2.write [1,2,3,4]
        end
      end
      EM::defer do
        50.times do
          sleep 0.1
          break if _tuple4
        end
        EM::add_timer 1 do
          EM::stop
        end
      end
    end
    assert_equal _tuple1, nil
    assert_equal _tuple2, nil
    assert_equal _tuple3, nil
    assert_equal _tuple4, [1,2,3]
  end

end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
em-rocketio-linda-client-0.0.3	test/test_client_disconnect.rb
em-rocketio-linda-client-0.0.2	test/test_client_disconnect.rb
em-rocketio-linda-client-0.0.1	test/test_client_disconnect.rb