File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -668,8 +668,13 @@ func TestShutdown(t *testing.T) {
668
668
node2 .c .Configure (testChannel , []cluster.RemoteNode {node1 .nodeInfo })
669
669
// Configuration of node doesn't take place
670
670
node1 .c .Configure (testChannel , []cluster.RemoteNode {node2 .nodeInfo })
671
+ gt := gomega .NewGomegaWithT (t )
672
+ gt .Eventually (func () (bool , error ) {
673
+ _ , err := node2 .c .Remote (testChannel , node1 .nodeInfo .ID )
674
+ return true , err
675
+ }).Should (gomega .BeTrue ())
676
+
671
677
stub , err := node2 .c .Remote (testChannel , node1 .nodeInfo .ID )
672
- assert .NoError (t , err )
673
678
// Therefore, sending a message doesn't succeed because node 1 rejected the configuration change
674
679
_ , err = stub .Step (testStepReq )
675
680
assert .EqualError (t , err , "rpc error: code = Unknown desc = channel test doesn't exist" )
You can’t perform that action at this time.
0 commit comments