Contents

module Rsift

  class Socket
  
    def self.perform(stream_identifier)
      endpoint = "ws://stream.datasift.net:8080/"
      EventMachine.run {
        http = EventMachine::HttpRequest.new(
            "#{endpoint}#{stream_identifier}").get(:timeout => 0)
    
        http.callback { puts "Connected to rsift" }
        http.errback { puts "something has failed" }
        http.disconnect { puts "oops, dropped connection?" }
    
        http.stream { |msg|
          yield
        }
      }
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rsift-0.3.2	lib/rsift/socket.rb