class Firehose::Client::Consumer::WebSocket
TODO - This won’t even work. Dropping ws:// above until this is tested. This thing should be sending message sequences to Firehose
. Connect to Firehose
via WebSockets and consume messages.
Attributes
logger[R]
url[R]
Public Class Methods
new(url, logger = Firehose.logger)
click to toggle source
# File lib/firehose/client/consumer.rb, line 35 def initialize(url, logger = Firehose.logger) @url, @logger = url, logger end
Public Instance Methods
request()
click to toggle source
# File lib/firehose/client/consumer.rb, line 39 def request ws = Faye::WebSocket::Client.new(url) ws.onmessage = lambda do |event| logger.info "WS | #{event.data[0...40].inspect}" end ws.onclose = lambda do |event| logger.info "WS | Closed" end ws.onerror do logger.error "WS | Failed" end end