Change ProducerMixingDifferentConfirmations test

Author: Gsantomaggio

README.md

@@ -254,7 +254,7 @@ var producer = await system.CreateProducer(
     });
 ```
 Then:
-```
+```csharp
 var publishingId = 0;
 var message = new Message(Encoding.UTF8.GetBytes($"my deduplicate message {i}"));
 await producer.Send(publishingId, message);

RabbitMQ.Stream.Client/SslHelper.cs

@@ -43,7 +43,7 @@ public static System.IO.Stream TcpUpgrade(System.IO.Stream tcpStream, SslOption
             var sslStream = new SslStream(tcpStream, false, remoteCertValidator, localCertSelector);
             try
             {
-                Action<SslOption> TryAuthenticating = (SslOption opts) =>
+                var TryAuthenticating = (SslOption opts) =>
                 {
                     sslStream.AuthenticateAsClientAsync(opts.ServerName, opts.Certs, opts.Version,
                         opts.CheckCertificateRevocation).GetAwaiter().GetResult();

Tests/ProducerSystemTests.cs

@@ -187,7 +187,7 @@ public async void ProducerMixingDifferentConfirmations()
                     ConfirmHandler = confirmation =>
                     {
                         count = Interlocked.Increment(ref count);
-                        if (count == 52)
+                        if (confirmation.PublishingId == 52)
                         {
                             testPassed.SetResult(true);
                         }
@@ -203,10 +203,10 @@ public async void ProducerMixingDifferentConfirmations()
             }
 
             await producer.Send(++pid, messages, CompressionType.Gzip);
-            Thread.Sleep(500);
-            Assert.Equal(ResponseCode.Ok, await producer.Close());
+            SystemUtils.Wait();
             new Utils<bool>(testOutputHelper).WaitUntilTaskCompletes(testPassed);
             Assert.Equal((ulong)52, count);
+            Assert.Equal(ResponseCode.Ok, await producer.Close());
             await system.DeleteStream(stream);
             await system.Close();
         }

Tests/Utils.cs

@@ -21,12 +21,12 @@ public class WaitTestBeforeAfter : BeforeAfterTestAttribute
     {
         public override void Before(MethodInfo methodUnderTest)
         {
-            Thread.Sleep(200);
+            Thread.Sleep(300);
         }
 
         public override void After(MethodInfo methodUnderTest)
         {
-            Thread.Sleep(200);
+            Thread.Sleep(300);
         }
     }