Merge pull request #279 from qdentity/fix-read-batch-size

Fix unused read batch size
commanded · Jan 8, 2024 · f313561 · f313561
2 parents b0ef771 + 9385c3f
commit f313561
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/lib/event_store.ex b/lib/event_store.ex
@@ -533,6 +533,12 @@ defmodule EventStore do
         conn = Keyword.get(opts, :conn) || Keyword.fetch!(config, :conn)
         timeout = timeout(opts, config)
 
+        config =
+          case Keyword.fetch(opts, :read_batch_size) do
+            {:ok, read_batch_size} -> Keyword.put(config, :read_batch_size, read_batch_size)
+            :error -> config
+          end
+
         {conn, Keyword.put(config, :timeout, timeout)}
       end