Add missed topic names (#426)

ThreeDotsLabs · Mar 5, 2024 · 9d4f783 · 9d4f783
1 parent c0aecac
commit 9d4f783
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pubsub/tests/test_pubsub.go b/pubsub/tests/test_pubsub.go
@@ -332,7 +332,7 @@ func TestConcurrentSubscribeMultipleTopics(
 	receivedMessagesCh := make(chan message.Messages, topicsCount)
 
 	for i := 0; i < topicsCount; i++ {
-		topicName := testTopicName(tCtx.TestID) + fmt.Sprintf("_%d", i)
+		topicName := testTopicName(tCtx.TestID) + fmt.Sprintf("-%d", i)
 
 		go func() {
 			defer subsWg.Done()
@@ -850,8 +850,8 @@ func TestTopic(
 	pub, sub := pubSubConstructor(t)
 	defer closePubSub(t, pub, sub)
 
-	topic1 := testTopicName(tCtx.TestID) + "_1"
-	topic2 := testTopicName(tCtx.TestID) + "_2"
+	topic1 := testTopicName(tCtx.TestID) + "-1"
+	topic2 := testTopicName(tCtx.TestID) + "-2"
 
 	if subscribeInitializer, ok := sub.(message.SubscribeInitializer); ok {
 		require.NoError(t, subscribeInitializer.SubscribeInitialize(topic1))