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
|
# File 'lib/em-websocket/message_processor_03.rb', line 6
def message(message_type, extension_data, application_data)
case message_type
when :close
if @state == :closing
@connection.close_connection
@state = :closed
else
send_frame(:close, application_data)
@state = :closed
@connection.close_connection_after_writing
end
when :ping
send_frame(:pong, application_data)
when :pong
when :text
if application_data.respond_to?(:force_encoding)
application_data.force_encoding("UTF-8")
end
@connection.trigger_on_message(application_data)
when :binary
@connection.trigger_on_message(application_data)
end
end
|