From 24e0449b7d37274810f9c455039ee2e48a3f087d Mon Sep 17 00:00:00 2001
From: Andrew Hampton <andrewwh@gmail.com>
Date: Thu, 3 Dec 2020 10:04:03 -0500
Subject: [PATCH] Make firehose buffer size configurable

---
 lib/firehose/server/message_buffer.rb | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/firehose/server/message_buffer.rb b/lib/firehose/server/message_buffer.rb
index 66b23104..a3eea500 100644
--- a/lib/firehose/server/message_buffer.rb
+++ b/lib/firehose/server/message_buffer.rb
@@ -5,7 +5,7 @@ module Server
     class MessageBuffer
       # Number of messages that Redis buffers for the client if its
       # connection drops, then reconnects.
-      DEFAULT_SIZE = 100
+      DEFAULT_SIZE = ENV.fetch("DEFAULT_BUFFER_SIZE", 100)
 
       def initialize(message_list, channel_sequence, consumer_sequence = nil)
         @message_list = message_list