Debounce adapter config option (#280)

app/models/concerns/cable_ready/updatable.rb

@@ -1,13 +1,12 @@
 # frozen_string_literal: true
 
 require "active_support/concern"
+require "cable_ready/config"
 
 module CableReady
   module Updatable
     extend ::ActiveSupport::Concern
 
-    mattr_accessor :debounce_adapter, default: ::CableReady::Updatable::MemoryCacheDebounceAdapter.instance
-
     included do |base|
       if defined?(ActiveRecord) && base < ActiveRecord::Base
         include ExtendHasMany
@@ -190,12 +189,12 @@ def broadcast_updates(model_class, options)
 
         if debounce_time.to_f > 0
           key = compound([model_class, *options])
-          old_wait_until = CableReady::Updatable.debounce_adapter[key]
+          old_wait_until = CableReady.config.updatable_debounce_adapter[key]
           now = Time.now.to_f
 
           if old_wait_until.nil? || old_wait_until < now
             new_wait_until = now + debounce_time.to_f
-            CableReady::Updatable.debounce_adapter[key] = new_wait_until
+            CableReady.config.updatable_debounce_adapter[key] = new_wait_until
             ActionCable.server.broadcast(model_class, options)
           end
         else

lib/cable_ready/config.rb

@@ -11,7 +11,7 @@ class Config
     include Observable
     include Singleton
 
-    attr_accessor :on_failed_sanity_checks, :broadcast_job_queue, :precompile_assets, :updatable_debounce_time
+    attr_accessor :on_failed_sanity_checks, :broadcast_job_queue, :precompile_assets, :updatable_debounce_time, :updatable_debounce_adapter
     attr_writer :verifier_key
 
     def on_new_version_available

lib/cable_ready/engine.rb

@@ -55,5 +55,9 @@ class Engine < Rails::Engine
         app.config.importmap.cache_sweepers << Engine.root.join("app/assets/javascripts")
       end
     end
+
+    config.after_initialize do
+      CableReady.config.updatable_debounce_adapter ||= CableReady::Updatable::MemoryCacheDebounceAdapter.instance
+    end
   end
 end