Module: EventMachine::WebSocket::MessageProcessor06
- Defined in:
- lib/em-websocket/message_processor_06.rb
Instance Method Summary collapse
- #message(message_type, extension_data, application_data) ⇒ Object
-
#pingable? ⇒ Boolean
Ping & Pong supported.
Instance Method Details
#message(message_type, extension_data, application_data) ⇒ Object
4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 |
# File 'lib/em-websocket/message_processor_06.rb', line 4 def (, extension_data, application_data) debug [:message_received, , application_data] case when :close status_code = case application_data.length when 0 # close messages MAY contain a body nil when 1 # Illegal close frame raise WSProtocolError, "Close frames with a body must contain a 2 byte status code" else application_data.slice!(0, 2).unpack('n').first end debug [:close_frame_received, status_code, application_data] if @state == :closing # We can close connection immediately since no more data may be # sent or received on this connection @connection.close_connection @state = :closed else # Acknowlege close # The connection is considered closed send_frame(:close, '') @state = :closed @connection.close_connection_after_writing # TODO: Send close status code and body to app code end when :ping # Pong back the same data send_frame(:pong, application_data) @connection.trigger_on_ping(application_data) when :pong @connection.trigger_on_pong(application_data) when :text if application_data.respond_to?(:force_encoding) application_data.force_encoding("UTF-8") end @connection.(application_data) when :binary @connection.(application_data) end end |
#pingable? ⇒ Boolean
Ping & Pong supported
52 53 54 |
# File 'lib/em-websocket/message_processor_06.rb', line 52 def pingable? true end |