Fixed Issue #40

bcg · Jul 19, 2012 · 4b0b8cc · 4b0b8cc
1 parent f2ce7ba
commit 4b0b8cc
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/lib/em-mongo/connection.rb b/lib/em-mongo/connection.rb
@@ -164,9 +164,11 @@ def receive_data(data)
       end
 
       if @buffer.more?
-        remaining_bytes= @buffer.size-@buffer.position
-        @buffer = BSON::ByteBuffer.new(@buffer.to_s[@buffer.position,remaining_bytes])
-        @buffer.rewind
+        if @buffer.position > 0
+          remaining_bytes= @buffer.size-@buffer.position
+          @buffer = BSON::ByteBuffer.new(@buffer.to_s[@buffer.position,remaining_bytes])
+          @buffer.rewind
+        end
       else
         @buffer.clear
       end