Sha256: bc38d6bc1bcd41f8a26cbad2bb1408dc1dc0a9b98d3eba72a03421b5f5c19a3a
Contents?: true
Size: 918 Bytes
Versions: 4
Compression:
Stored size: 918 Bytes
Contents
require 'pubnub' TIMES = 1000 @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}" puts this.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 @paths << envelope.path } sleep 3 TIMES.times do |i| sleep 0.25 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}" #binding.pry
Version data entries
4 entries across 4 versions & 2 rubygems
Version | Path |
---|---|
pubnub-ruby-3.4.1 | examples/serial_publish.rb |
pubnub-3.4.1 | examples/serial_publish.rb |
pubnub-ruby-3.4 | examples/serial_publish.rb |
pubnub-3.4 | examples/serial_publish.rb |