chore: fix a debug script (#393)

redis-rb · Oct 1, 2024 · 97707c5 · 97707c5
1 parent 2212a8f
commit 97707c5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/bin/pubsub b/bin/pubsub
@@ -49,6 +49,7 @@ module PubSubDebug
         handle_errors('Subscriber') do
           e = ps.next_event(0.01)
           log "#{role}: recv: #{e.nil? ? 'nil' : e}"
+          ps.call('ssubscribe', c) if e.first == 'sunsubscribe'
         end
       ensure
         sleep 1.0

diff --git a/test/test_against_cluster_down.rb b/test/test_against_cluster_down.rb
@@ -164,6 +164,7 @@ def spawn_subscriber(cli, rec)
           event = ps.next_event(0.01)
           case event&.first
           when 'smessage' then r.set(event[2])
+          when 'sunsubscribe' then ps.call('ssubscribe', 'chan')
           end
         end
       ensure