class WebsocketRails::ConnectionAdapters::WebSocket

Public Class Methods

accepts?(env) click to toggle source
# File lib/websocket_rails/connection_adapters/web_socket.rb, line 5
def self.accepts?(env)
  Faye::WebSocket.websocket?( env )
end
new(request, dispatcher) click to toggle source
# File lib/websocket_rails/connection_adapters/web_socket.rb, line 9
def initialize(request, dispatcher)
  super
  @connection = Faye::WebSocket.new(request.env)
  @connection.onmessage = method(:on_message)
  @connection.onerror   = method(:on_error)
  @connection.onclose   = method(:on_close)
  @connection.rack_response
  EM.next_tick do
    on_open
  end
end

Public Instance Methods

close!() click to toggle source
# File lib/websocket_rails/connection_adapters/web_socket.rb, line 30
def close!
  @connection.close
end
on_message(event) click to toggle source
# File lib/websocket_rails/connection_adapters/web_socket.rb, line 25
def on_message(event)
  data = event.respond_to?(:data) ? event.data : event
  super data
end
send(message) click to toggle source
# File lib/websocket_rails/connection_adapters/web_socket.rb, line 21
def send(message)
  @connection.send message
end