remove pack/unpack overhead

bcg · Sep 13, 2011 · 6932aa6 · 6932aa6
1 parent f806c48
commit 6932aa6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/em-mongo/connection.rb b/lib/em-mongo/connection.rb
@@ -154,7 +154,7 @@ def peek_size(buffer)
 
     def receive_data(data)
 
-      @buffer.append!(BSON::ByteBuffer.new(data.unpack('C*')))
+      @buffer.append!(data)
 
       @buffer.rewind
       while message_received?(@buffer)
@@ -165,7 +165,7 @@ def receive_data(data)
 
       if @buffer.more?
         remaining_bytes= @buffer.size-@buffer.position
-        @buffer = BSON::ByteBuffer.new(@buffer.get(remaining_bytes))
+        @buffer = BSON::ByteBuffer.new(@buffer.to_s[@buffer.position,remaining_bytes])
         @buffer.rewind
       else
         @buffer.clear