Skip to content

Commit 97707c5

Browse files
authored
chore: fix a debug script (#393)
1 parent 2212a8f commit 97707c5

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

bin/pubsub

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@ module PubSubDebug
4949
handle_errors('Subscriber') do
5050
e = ps.next_event(0.01)
5151
log "#{role}: recv: #{e.nil? ? 'nil' : e}"
52+
ps.call('ssubscribe', c) if e.first == 'sunsubscribe'
5253
end
5354
ensure
5455
sleep 1.0

test/test_against_cluster_down.rb

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -164,6 +164,7 @@ def spawn_subscriber(cli, rec)
164164
event = ps.next_event(0.01)
165165
case event&.first
166166
when 'smessage' then r.set(event[2])
167+
when 'sunsubscribe' then ps.call('ssubscribe', 'chan')
167168
end
168169
end
169170
ensure

0 commit comments

Comments
 (0)