Class: SockJS::Transports::RawWebSocket

Inherits:
WebSocket show all
Defined in:
lib/sockjs/transports/websocket.rb

Instance Attribute Summary

Attributes inherited from Endpoint

#connection, #options

Attributes included from Endpoint::ClassMethods

#method, #prefix

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from WebSocket

#build_error_response, #build_response, #disabled?, #finish_response, #format_frame, #handle_request, #process_session, #send_data, #session_key

Methods inherited from ConsumingTransport

#finish_response, #format_frame, #get_session, #process_session, #request_closed, #send_data

Methods inherited from SockJS::Transport

#exception_response, #handle_request, #handle_session_unavailable, #request_data, #response_beginning, #server_key, #session_key

Methods inherited from Endpoint

#build_error_response, #build_response, #call, #empty_string, #error_content_type, #format_frame, #handle, #handle_http_error, #handle_request, #initialize, #inspect, #response_class, #setup_response

Methods included from Endpoint::ClassMethods

#add_route, #add_routes, #endpoints, #register, #route_conditions, #routing_prefix

Constructor Details

This class inherits a constructor from SockJS::Endpoint

Class Method Details

.routing_prefix ⇒ Object 



137
138
139
 
# File 'lib/sockjs/transports/websocket.rb', line 137

def self.routing_prefix
  "/" + self.prefix
end

Instance Method Details

#closing_frame(response, status, message) ⇒ Object 



161
162
163
 
# File 'lib/sockjs/transports/websocket.rb', line 161

def closing_frame(response, status, message)
  finish_response(response)
end

#extract_message(event) ⇒ Object 



147
148
149
150
 
# File 'lib/sockjs/transports/websocket.rb', line 147

def extract_message(event)
  SockJS.debug "Received message event: #{event.data.inspect}"
  event.data.to_json
end

#heartbeat_frame(response) ⇒ Object 



144
145
 
# File 'lib/sockjs/transports/websocket.rb', line 144

def heartbeat_frame(response)
end

#messages_frame(websocket, messages) ⇒ Object 



152
153
154
155
156
157
158
159
 
# File 'lib/sockjs/transports/websocket.rb', line 152

def messages_frame(websocket, messages)
  messages.inject(0) do |sent_count, data|
    send_data(websocket, data)
    sent_count + data.length
  end
rescue Object => ex
  SockJS::debug "Error delivering messages to raw websocket: #{messages.inspect} #{ex.inspect}"
end

#opening_frame(response) ⇒ Object 



141
142
 
# File 'lib/sockjs/transports/websocket.rb', line 141

def opening_frame(response)
end