diff --git a/contrib/extension/subscription/client_test.go b/contrib/extension/subscription/client_test.go
index ab3f77760e559e046e73a9271eab694c033ddc50..8fe32e7945505856f3a4e43cdabdac683d66b299 100644
--- a/contrib/extension/subscription/client_test.go
+++ b/contrib/extension/subscription/client_test.go
@@ -38,19 +38,17 @@ func newRouter(t *testing.T) jmux.Router {
 		}
 		var count int
 		_ = json.Unmarshal(r.Params, &count)
-		go func() {
-			time.Sleep(10 * time.Millisecond)
-			for idx := 0; count == 0 || idx < count; idx++ {
-				select {
-				case <-r.Context().Done():
-					return
-				case <-notifier.Err():
-					return
-				default:
-				}
-				_ = notifier.Notify(idx)
+		time.Sleep(10 * time.Millisecond)
+		for idx := 0; count == 0 || idx < count; idx++ {
+			select {
+			case <-r.Context().Done():
+				return
+			case <-notifier.Err():
+				return
+			default:
 			}
-		}()
+			_ = notifier.Notify(idx)
+		}
 	})
 
 	return r