Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- require 'eventmachine'
- require 'em-http'
- EventMachine.run {
- http = EventMachine::HttpRequest.new("ws://localhost:8080/").get :timeout => 0
- # evlauation setup
- http.errback {|err| puts "oops #{err}" }
- http.disconnect {
- puts "connection closed"
- }
- http.callback {
- # puts http.response
- # puts message.inspect
- # puts "Got message: #{message}"
- # sleep(rand(10))
- # http.send(message.reverse)
- # puts "WebSocket connected!"
- # sleep(10) # e.g. evaluatate
- # http.send("did it: you scored 0")
- }
- http.stream {|message|
- puts "Got message: #{message}\nworking..."
- sleep(rand(10))
- puts "done!"
- http.send("did it: you scored #{message.length}")
- }
- # send messages back
- # http.stream { |msg|
- # sleep(10)
- # http.send("got your message #{msg}")
- # }
- #
- # timer = EventMachine::PeriodicTimer.new(1) do
- # http.send(Time.now.to_s)
- # end
- }
Add Comment
Please, Sign In to add comment