From d1e3d4b44e754a96033fef44d15d03583380c9d5 Mon Sep 17 00:00:00 2001 From: Nick Pezza Date: Thu, 12 Sep 2024 17:28:16 -0400 Subject: [PATCH] Fix adapter test --- lib/solid_cable.rb | 2 +- .../lib/action_cable/subscription_adapter/solid_cable_test.rb | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/solid_cable.rb b/lib/solid_cable.rb index b552d19..0d52dd3 100644 --- a/lib/solid_cable.rb +++ b/lib/solid_cable.rb @@ -27,7 +27,7 @@ def autotrim? end def trim_batch_size - if (size = cable_config.trim_batch_size.to_i) < 2 + if (size = cable_config.trim_batch_size.to_i) < 1 100 else size diff --git a/test/lib/action_cable/subscription_adapter/solid_cable_test.rb b/test/lib/action_cable/subscription_adapter/solid_cable_test.rb index ea394ac..30e5150 100644 --- a/test/lib/action_cable/subscription_adapter/solid_cable_test.rb +++ b/test/lib/action_cable/subscription_adapter/solid_cable_test.rb @@ -64,7 +64,7 @@ class ActionCable::SubscriptionAdapter::SolidCableTest < ActionCable::TestCase test "trims_after_unsubscribe" do SolidCable.stub(:trim_chance, 99.999) do - with_cable_config message_retention: "1.second", trim_batch_size: 2 do + with_cable_config message_retention: "2.seconds", trim_batch_size: 1 do subscribe_as_queue("channel") do |queue| 4.times do @tx_adapter.broadcast("channel", "hello world") @@ -73,7 +73,7 @@ class ActionCable::SubscriptionAdapter::SolidCableTest < ActionCable::TestCase queue.clear end - assert_equal 0, SolidCable::Message.where(channel: "channel").count + assert_equal 1, SolidCable::Message.where(channel: "channel").count end end end