remove parallel tests

jxsl13 · Mar 15, 2024 · f5cfb80 · f5cfb80
1 parent acda79f
commit f5cfb80
Show file tree

Hide file tree

Showing 4 changed files with 1 addition and 11 deletions.
diff --git a/pool/connection_test.go b/pool/connection_test.go
@@ -13,7 +13,7 @@ import (
 )
 
 func TestNewSingleConnection(t *testing.T) {
-	t.Parallel() // can be run in parallel because the connection to the rabbitmq is never broken
+
 	var (
 		ctx      = context.TODO()
 		nextName = testutils.ConnectionNameGenerator()
@@ -36,7 +36,6 @@ func TestNewSingleConnection(t *testing.T) {
 }
 
 func TestManyNewConnection(t *testing.T) {
-	t.Parallel() // can be run in parallel because the connection to the rabbitmq is never broken
 
 	var (
 		ctx         = context.TODO()
@@ -74,7 +73,6 @@ func TestManyNewConnection(t *testing.T) {
 }
 
 func TestNewSingleConnectionWithDisconnect(t *testing.T) {
-	t.Parallel()
 	var (
 		ctx                      = context.TODO()
 		proxyName, connectURL, _ = testutils.NextConnectURL()
@@ -101,7 +99,6 @@ func TestNewSingleConnectionWithDisconnect(t *testing.T) {
 }
 
 func TestManyNewConnectionWithDisconnect(t *testing.T) {
-	t.Parallel()
 
 	var (
 		ctx                      = context.TODO()

diff --git a/pool/pool_test.go b/pool/pool_test.go
@@ -17,7 +17,6 @@ func TestMain(m *testing.M) {
 }
 
 func TestNewPool(t *testing.T) {
-	t.Parallel() // can be run in parallel because the connection to the rabbitmq is never broken
 
 	var (
 		ctx         = context.TODO()

diff --git a/pool/session_pool_test.go b/pool/session_pool_test.go
@@ -13,7 +13,6 @@ import (
 )
 
 func TestSingleSessionPool(t *testing.T) {
-	t.Parallel() // can be run in parallel because the connection to the rabbitmq is never
 
 	var (
 		poolName    = testutils.FuncName()
@@ -56,7 +55,6 @@ func TestSingleSessionPool(t *testing.T) {
 }
 
 func TestNewSessionPool(t *testing.T) {
-	t.Parallel() // can be run in parallel because the connection to the rabbitmq is never
 
 	var (
 		poolName    = testutils.FuncName()

diff --git a/pool/subscriber_test.go b/pool/subscriber_test.go
@@ -14,7 +14,6 @@ import (
 )
 
 func TestNewSingleSubscriber(t *testing.T) {
-	t.Parallel()
 
 	var (
 		ctx          = context.TODO()
@@ -54,7 +53,6 @@ func TestNewSingleSubscriber(t *testing.T) {
 }
 
 func TestNewSingleSubscriberWithDisconnect(t *testing.T) {
-	t.Parallel()
 
 	var (
 		ctx                       = context.TODO()
@@ -99,7 +97,6 @@ func TestNewSingleSubscriberWithDisconnect(t *testing.T) {
 }
 
 func TestNewSingleBatchSubscriber(t *testing.T) {
-	t.Parallel()
 
 	var (
 		ctx          = context.TODO()
@@ -152,7 +149,6 @@ func TestNewSingleBatchSubscriber(t *testing.T) {
 }
 
 func TestBatchSubscriberMaxBytes(t *testing.T) {
-	t.Parallel()
 	var wg sync.WaitGroup
 	funcName := testutils.FuncName()
-Original file line number
+Diff line change
@@ Expand Up / @@ -17,7 +17,6 @@ func TestMain(m *testing.M) { @@
     }
     func TestNewPool(t *testing.T) {
-    	t.Parallel() // can be run in parallel because the connection to the rabbitmq is never broken
     	var (
     		ctx         = context.TODO()
@@ Expand Down @@