Cleanup the tests

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
nats-io · Nov 15, 2023 · 3111ba6 · 3111ba6
1 parent 79c80b6
commit 3111ba6
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/jetstream/test/ordered_test.go b/jetstream/test/ordered_test.go
@@ -1414,7 +1414,10 @@ func TestOrderedConsumerNextOrder(t *testing.T) {
 
 	go func() {
 		for i := 0; i < 100_000; i++ {
-			js.Publish(ctx, "FOO.A", []byte(fmt.Sprintf("%d", 1)))
+			_, err := js.Publish(ctx, "FOO.A", []byte(fmt.Sprintf("%d", 1)))
+			if err != nil {
+				t.Fatalf("Unexpected error while publishing: %v", err)
+			}
 		}
 	}()
 
@@ -1429,12 +1432,10 @@ func TestOrderedConsumerNextOrder(t *testing.T) {
 
 	for i := 0; i < 100_000; i++ {
 
-		fmt.Printf("i: %d\n", i)
 		msg, err := c.Next(jetstream.FetchMaxWait(5 * time.Second))
 		if err != nil {
 			t.Fatalf("Unexpected error: %v", err)
 		}
-		fmt.Println("got some message ", i)
 		meta, err := msg.Metadata()
 		if err != nil {
 			t.Fatalf("Unexpected error: %v", err)