Sha256: bea338e74f56e6c1a8081ab1fe9861dac237ee59dc33ce8219fd3c69d611eccd

Contents?: true

Size: 856 Bytes

Versions: 19

Compression:

Stored size: 856 Bytes

Contents

require 'pubnub'

TIMES = 10000

@msgs = Array.new
@timetokens = Array.new
@envelopes = Array.new
@responses = Array.new
@paths = Array.new
@publish_responses = Array.new
@last = 0

p = Pubnub.new(
    #:origin         => 'localhost',
    :subscribe_key  => 'demo',
    :publish_key    => 'demo',
    :error_callback => lambda{ |e|
      puts "ERROR! #{e.inspect}"
    }
)

p.subscribe(:channel => 'my_channel_123'){ |envelope|
  #p envelope.msg
  @last = envelope.msg.to_i
  @msgs << envelope.msg
  @timetokens << envelope.timetoken
  @envelopes << envelope
  @responses << envelope.response
}

sleep 3

TIMES.times do |i|
  sleep 0.05
  p.publish(:message => i+1, :channel => 'my_channel_123', :http_sync => false){|envelope|
    print '.'
    @publish_responses << envelope.response
  }
end
while @last < TIMES do end

puts "\nmsgs size: #{@msgs.size}"

Version data entries

19 entries across 19 versions & 1 rubygems

Version Path
pubnub-3.7.12 examples/serial_publish.rb
pubnub-3.7.11 examples/serial_publish.rb
pubnub-3.7.10 examples/serial_publish.rb
pubnub-3.7.9 examples/serial_publish.rb
pubnub-3.7.7 examples/serial_publish.rb
pubnub-3.7.5 examples/serial_publish.rb
pubnub-3.7.1 examples/serial_publish.rb
pubnub-3.7.0 examples/serial_publish.rb
pubnub-3.6.10 examples/serial_publish.rb
pubnub-3.6.9 examples/serial_publish.rb
pubnub-3.6.7 examples/serial_publish.rb
pubnub-3.5.14 examples/serial_publish.rb
pubnub-3.5.12 examples/serial_publish.rb
pubnub-3.5.8 examples/serial_publish.rb
pubnub-3.5.7 examples/serial_publish.rb
pubnub-3.5.6 examples/serial_publish.rb
pubnub-3.5.5 examples/serial_publish.rb
pubnub-3.5.3 examples/serial_publish.rb
pubnub-3.5.1 examples/serial_publish.rb