@@ -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