Guest User

Untitled

a guest
Jun 17th, 2018
78
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.90 KB | None | 0 0
  1. require 'eventmachine'
  2. require 'em-http'
  3.  
  4. EventMachine.run {
  5. http = EventMachine::HttpRequest.new("ws://localhost:8080/").get :timeout => 0
  6. # evlauation setup
  7. http.errback {|err| puts "oops #{err}" }
  8.  
  9. http.disconnect {
  10. puts "connection closed"
  11. }
  12.  
  13. http.callback {
  14. # puts http.response
  15.  
  16. # puts message.inspect
  17. # puts "Got message: #{message}"
  18. # sleep(rand(10))
  19. # http.send(message.reverse)
  20. # puts "WebSocket connected!"
  21. # sleep(10) # e.g. evaluatate
  22. # http.send("did it: you scored 0")
  23.  
  24. }
  25. http.stream {|message|
  26. puts "Got message: #{message}\nworking..."
  27. sleep(rand(10))
  28. puts "done!"
  29. http.send("did it: you scored #{message.length}")
  30. }
  31. # send messages back
  32. # http.stream { |msg|
  33. # sleep(10)
  34. # http.send("got your message #{msg}")
  35. # }
  36. #
  37. # timer = EventMachine::PeriodicTimer.new(1) do
  38. # http.send(Time.now.to_s)
  39. # end
  40. }
Add Comment
Please, Sign In to add comment