From 9385c3f339a00c265241e3156627ce2bcdae9d3f Mon Sep 17 00:00:00 2001 From: dvic Date: Fri, 3 Nov 2023 20:30:52 +0100 Subject: [PATCH] Fix unused read batch size --- lib/event_store.ex | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/lib/event_store.ex b/lib/event_store.ex index c571254a..a7b63b5f 100644 --- 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