We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e97899e commit 20fc2cdCopy full SHA for 20fc2cd
cluster_test.go
@@ -6843,9 +6843,8 @@ func TestClusterClient_SendReadOperationToReplicaNodeWriteOperationToPrimaryNode
6843
return e
6844
},
6845
}
6846
- primaryNodeConn.AcquireFn = func() wire {
6847
- return w
6848
- }
+ primaryNodeConn.AcquireFn = func() wire { return w }
+ replicaNodeConn.AcquireFn = func() wire { return w } // Subscribe can work on replicas
6849
if err := client.Dedicated(func(c DedicatedClient) error {
6850
return c.Receive(context.Background(), c.B().Subscribe().Channel("a").Build(), func(msg PubSubMessage) {})
6851
}); err != e {
0 commit comments