Set connection transport buffer for active socket

whatyouhide · Apr 16, 2024 · 071382a · 071382a
1 parent 077cc5f
commit 071382a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/xandra/connection.ex b/lib/xandra/connection.ex
@@ -18,6 +18,7 @@ defmodule Xandra.Connection do
   @behaviour :gen_statem
 
   @forced_transport_options [packet: :raw, mode: :binary, active: false]
+  @default_transport_options [buffer: 1_000_000]
 
   # How old a timed-out stream ID can be before we flush it.
   @max_timed_out_stream_id_age_in_millisec :timer.minutes(5)
@@ -410,6 +411,7 @@ defmodule Xandra.Connection do
       options:
         options
         |> Keyword.get(:transport_options, [])
+        |> Keyword.put_new(@default_transport_options)
         |> Keyword.merge(@forced_transport_options)
     }