@@ -325,16 +325,16 @@ public async void ProducerBatchConfirmNumberOfMessages()
325325            const  int  NumberOfMessages  =  100 ; 
326326            var  rawProducer  =  await  system . CreateRawProducer ( new 
327327                RawProducerConfig ( stream ) 
328+             { 
329+                 Reference  =  "producer" , 
330+                 ConfirmHandler  =  confirmation => 
328331                { 
329-                     Reference  =  "producer" , 
330-                     ConfirmHandler  =  confirmation => 
332+                     if  ( confirmation . PublishingId  ==  NumberOfMessages ) 
331333                    { 
332-                         if  ( confirmation . PublishingId  ==  NumberOfMessages ) 
333-                         { 
334-                             testPassed . SetResult ( true ) ; 
335-                         } 
334+                         testPassed . SetResult ( true ) ; 
336335                    } 
337336                } 
337+             } 
338338            ) ; 
339339            var  messages  =  new  List < ( ulong ,  Message ) > ( ) ; 
340340            for  ( var  i  =  1 ;  i  <=  NumberOfMessages ;  i ++ ) 
@@ -386,9 +386,10 @@ public async Task ProducerSendsArrays255Bytes(ReadOnlySequence<byte> @event)
386386            var  testPassed  =  new  TaskCompletionSource < bool > ( ) ; 
387387            var  rawProducer  =  await  system . CreateRawProducer ( new 
388388                RawProducerConfig ( stream ) 
389-                 { 
390-                     Reference  =  "producer" ,  ConfirmHandler  =  _ =>  {  testPassed . SetResult ( true ) ;  } 
391-                 } 
389+             { 
390+                 Reference  =  "producer" , 
391+                 ConfirmHandler  =  _ =>  {  testPassed . SetResult ( true ) ;  } 
392+             } 
392393            ) ; 
393394
394395            const  ulong  PublishingId  =  0 ; 
0 commit comments