Sha256: b8c32e0ca3009bc96741fe808622cdad7f5e24eb01e72494ba5126a124fd6895
Contents?: true
Size: 1.14 KB
Versions: 13
Compression:
Stored size: 1.14 KB
Contents
require File.expand_path 'test_helper', File.dirname(__FILE__) require 'sinatra/rocketio/linda/client' class TestClientDisconnect < MiniTest::Test def test_client_disconnect ts_name = "ts_#{Time.now.to_i}_#{Time.now.usec}" client1 = Sinatra::RocketIO::Linda::Client.new App.url _tuple1 = nil _tuple2 = nil _tuple3 = nil _tuple4 = nil client1.io.on :connect do client2 = Sinatra::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 50.times do sleep 0.1 break if _tuple4 end assert_equal _tuple1, nil assert_equal _tuple2, nil assert_equal _tuple3, nil assert_equal _tuple4, [1,2,3] end end
Version data entries
13 entries across 13 versions & 1 rubygems