Support binary

Author: mloughran

lib/em-websocket/connection.rb

@@ -10,12 +10,16 @@ def onopen(&blk);     @onopen = blk;    end
       def onclose(&blk);    @onclose = blk;   end
       def onerror(&blk);    @onerror = blk;   end
       def onmessage(&blk);  @onmessage = blk; end
+      def onbinary(&blk);   @onbinary = blk; end
       def onping(&blk);     @onping = blk;    end
       def onpong(&blk);     @onpong = blk;    end
 
       def trigger_on_message(msg)
         @onmessage.call(msg) if defined? @onmessage
       end
+      def trigger_on_binary(msg)
+        @onbinary.call(msg) if defined? @onbinary
+      end
       def trigger_on_open(handshake)
         @onopen.call(handshake) if defined? @onopen
       end

lib/em-websocket/message_processor_03.rb

@@ -34,7 +34,7 @@ def message(message_type, extension_data, application_data)
           end
           @connection.trigger_on_message(application_data)
         when :binary
-          @connection.trigger_on_message(application_data)
+          @connection.trigger_on_binary(application_data)
         end
       end
 

lib/em-websocket/message_processor_06.rb

@@ -51,7 +51,7 @@ def message(message_type, extension_data, application_data)
           end
           @connection.trigger_on_message(application_data)
         when :binary
-          @connection.trigger_on_message(application_data)
+          @connection.trigger_on_binary(application_data)
         end
       end
 

spec/integration/draft03_spec.rb

@@ -114,7 +114,8 @@ def start_client
         data = "a" * 256
 
         start_server { |ws|
-          ws.onmessage { |msg|
+          ws.onbinary { |msg|
+            msg.encoding.should == Encoding.find("BINARY") if defined?(Encoding)
             msg.should == data
             done
           }
@@ -134,7 +135,8 @@ def start_client
         data = "a" * 65536
 
         start_server { |ws|
-          ws.onmessage { |msg|
+          ws.onbinary { |msg|
+            msg.encoding.should == Encoding.find("BINARY") if defined?(Encoding)
             msg.should == data
             done
           }