try to fix gcp

lillo42 · lillo42 · commit 0cb36a4c88e3 · 2026-04-25T21:40:20.000+01:00
diff --git a/tests/Paramore.Brighter.Gcp.Tests/MessagingGateway/GcpPullMessageGatewayProvider.cs b/tests/Paramore.Brighter.Gcp.Tests/MessagingGateway/GcpPullMessageGatewayProvider.cs
@@ -210,7 +210,10 @@ public async Task CleanUpAsync(
         IEnumerable<Message> messages
     )
     {
-        channel?.Dispose();
+        if (channel != null)
+        {
+            await channel.DisposeAsync();
+        }
 
         if (producer != null)
         {
diff --git a/tests/Paramore.Brighter.Gcp.Tests/MessagingGateway/GcpPullOrderingMessageGatewayProvider.cs b/tests/Paramore.Brighter.Gcp.Tests/MessagingGateway/GcpPullOrderingMessageGatewayProvider.cs
@@ -222,7 +222,10 @@ public async Task CleanUpAsync(
         IEnumerable<Message> messages
     )
     {
-        channel?.Dispose();
+        if (channel != null)
+        {
+            await channel.DisposeAsync();
+        }
 
         if (producer != null)
         {
diff --git a/tests/Paramore.Brighter.Gcp.Tests/MessagingGateway/GcpStreamMessageGatewayProvider.cs b/tests/Paramore.Brighter.Gcp.Tests/MessagingGateway/GcpStreamMessageGatewayProvider.cs
@@ -210,7 +210,10 @@ public async Task CleanUpAsync(
         IEnumerable<Message> messages
     )
     {
-        channel?.Dispose();
+        if (channel != null)
+        {
+            await channel.DisposeAsync();
+        }
 
         if (producer != null)
         {
diff --git a/tests/Paramore.Brighter.Gcp.Tests/MessagingGateway/GcpStreamOrderingMessageGatewayProvider.cs b/tests/Paramore.Brighter.Gcp.Tests/MessagingGateway/GcpStreamOrderingMessageGatewayProvider.cs
@@ -222,7 +222,10 @@ public async Task CleanUpAsync(
         IEnumerable<Message> messages
     )
     {
-        channel?.Dispose();
+        if (channel != null)
+        {
+            await channel.DisposeAsync();
+        }
 
         if (producer != null)
         {

Original file line number	Diff line number	Diff line change
`@@ -210,7 +210,10 @@ public async Task CleanUpAsync(`
`210`	`210`	`IEnumerable<Message> messages`
`211`	`211`	`)`
`212`	`212`	`{`
`213`		`- channel?.Dispose();`
	`213`	`+ if (channel != null)`
	`214`	`+ {`
	`215`	`+ await channel.DisposeAsync();`
	`216`	`+ }`
`214`	`217`
`215`	`218`	`if (producer != null)`
`216`	`219`	`{`
Original file line number	Diff line number	Diff line change
`@@ -222,7 +222,10 @@ public async Task CleanUpAsync(`
`222`	`222`	`IEnumerable<Message> messages`
`223`	`223`	`)`
`224`	`224`	`{`
`225`		`- channel?.Dispose();`
	`225`	`+ if (channel != null)`
	`226`	`+ {`
	`227`	`+ await channel.DisposeAsync();`
	`228`	`+ }`
`226`	`229`
`227`	`230`	`if (producer != null)`
`228`	`231`	`{`