Skip to content

Commit af43e9c

Browse files
committed
1 parent 2b835c0 commit af43e9c

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

lib/mongo/connection.rb

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -750,7 +750,8 @@ def send_message_on_socket(packed_message, socket)
750750
# Requires length and an available socket.
751751
def receive_message_on_socket(length, socket)
752752
begin
753-
message = socket.read(length)
753+
message = new_binary_string
754+
socket.read(length, message)
754755
raise ConnectionFailure, "connection closed" unless message.length > 0
755756
if message.length < length
756757
chunk = new_binary_string

0 commit comments

Comments
 (0)