module Redis::Connection::SocketMixin

def read(nbytes)
  result = @buffer.slice!(0, nbytes)
  while result.bytesize < nbytes
    result << _read_from_socket(nbytes - result.bytesize)
  end
  result
end