Merge commit 'e1f73c4' into bcg_buffer_perf

bcg · Sep 13, 2011 · 0ec1ed7 · 0ec1ed7
2 parents e0a9fd8 + e1f73c4
commit 0ec1ed7
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/lib/em-mongo/server_response.rb b/lib/em-mongo/server_response.rb
@@ -21,10 +21,14 @@ def initialize(buffer, connection)
       @number_returned  = buffer.get_int
 
       # Documents
-      @docs = (1..number_returned).map do
+      pos=buffer.position
+      @docs = (1..@number_returned).map do
         size= @connection.peek_size(buffer)
-        buf = buffer.get(size)
-        BSON::BSON_CODER.deserialize(buf)
+
+        doc=CBson.deserialize(buffer.to_s[pos,size])
+        pos+=size
+        buffer.position=pos
+        doc
       end
     end