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