Method: StreamTest#test_process100

Defined in:
lib/vendor/xmpp4r/test/tc_stream.rb

#test_process100 ⇒ Object 



48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'lib/vendor/xmpp4r/test/tc_stream.rb', line 48

def test_process100
  @server.puts(STREAM)
  @server.flush

  done = Semaphore.new
  n = 0
  @stream.add_message_callback {
    n += 1
    done.run if n % 100 == 0
  }

  100.times {
    @server.puts('<message/>')
    @server.flush
  }

  done.wait
  assert_equal(100, n)

  @server.puts('<message/>' * 100)
  @server.flush

  done.wait
  assert_equal(200, n)
end