Fix flapping test

Signed-off-by: Derek Collison <derek@nats.io>
nats-io · Feb 28, 2023 · e143cb0 · e143cb0
1 parent bab10c1
commit e143cb0
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/server/jetstream_super_cluster_test.go b/server/jetstream_super_cluster_test.go
@@ -2082,14 +2082,9 @@ func TestJetStreamSuperClusterMovingStreamAndMoveBack(t *testing.T) {
 
 			toSend := 10_000
 			for i := 0; i < toSend; i++ {
-				_, err := js.PublishAsync("TEST", []byte("HELLO WORLD"))
+				_, err := js.Publish("TEST", []byte("HELLO WORLD"))
 				require_NoError(t, err)
 			}
-			select {
-			case <-js.PublishAsyncComplete():
-			case <-time.After(5 * time.Second):
-				t.Fatalf("Did not receive completion signal")
-			}
 
 			_, err = js.UpdateStream(&nats.StreamConfig{
 				Name:      "TEST",