fix: the behavior of subscription in pubsub when nodes are unstable #1006

Job	Run time
Benchmark	2m 45s
IPS	3m 2s
Main (7.2, 3.3)	1m 8s
Lint	10s
Main (7.2, 3.3, compose.ssl.yaml)	1m 25s
Massive Cluster	6m 15s
Main (7.2, 3.3, hiredis)	1m 6s
NAT-ted Environments	1m 9s
Main (7.2, 3.3, hiredis, compose.ssl.yaml)	2m 11s
Profiling (single)	49s
Main (7.2, 3.3, compose.replica.yaml, 2)	1m 8s
Profiling (excessive_pipelining)	39s
Main (test_cluster_down)	4m 21s
Profiling (pipelining_in_moderation)	38s
Main (test_cluster_broken, no, 6)	2m 1s
Profiling (original_mget)	41s
Main (8, 3.3, compose.valkey.yaml, 2)	1m 10s
Profiling (emulated_mget)	57s
Main (7.2, 3.2, compose.auth.yaml)	1m 10s
Main (7.0, 3.1)	1m 8s
Main (6.2, 3.0)	1m 6s
Main (5.0, 2.7)	1m 24s
Main (test_cluster_state, PrimaryOnly, compose.valkey.yaml, 8, 2, 9)	2m 5s
Main (test_cluster_state, Pooled, compose.valkey.yaml, 8, 2, 9)	2m 7s
Main (test_cluster_state, ScaleReadRandom, compose.valkey.yaml, 8, 2, 9)	2m 3s
Main (test_cluster_state, ScaleReadRandomWithPrimary, compose.valkey.yaml, 8, 2, 9)	2m 4s
Main (test_cluster_state, ScaleReadLatency, compose.valkey.yaml, 8, 2, 9)	2m 1s
Main (jruby)	1m 43s
Main (truffleruby)	1m 21s
Main (test_cluster_scale, Single, compose.scale.yaml, 8)	1m 13s
Main (test_cluster_scale, Pipeline, compose.scale.yaml, 8)	1m 14s
Main (test_cluster_scale, Transaction, compose.scale.yaml, 8)	1m 12s
Main (test_cluster_scale, PubSub, compose.scale.yaml, 8)	1m 40s
	55m 6s

Provide feedback