diff --git a/lib/xandra/connection.ex b/lib/xandra/connection.ex index e1794154..1fcc733b 100644 --- a/lib/xandra/connection.ex +++ b/lib/xandra/connection.ex @@ -646,7 +646,6 @@ defmodule Xandra.Connection do def connected(:info, message, data) when is_data_message(data.transport, message) do :ok = Transport.setopts(data.transport, active: :once) {_mod, _socket, bytes} = message - data = update_in(data.buffer, &(&1 <> bytes)) handle_new_bytes(data) end