@@ -325,16 +325,16 @@ public async void ProducerBatchConfirmNumberOfMessages()
325
325
const int NumberOfMessages = 100 ;
326
326
var rawProducer = await system . CreateRawProducer ( new
327
327
RawProducerConfig ( stream )
328
+ {
329
+ Reference = "producer" ,
330
+ ConfirmHandler = confirmation =>
328
331
{
329
- Reference = "producer" ,
330
- ConfirmHandler = confirmation =>
332
+ if ( confirmation . PublishingId == NumberOfMessages )
331
333
{
332
- if ( confirmation . PublishingId == NumberOfMessages )
333
- {
334
- testPassed . SetResult ( true ) ;
335
- }
334
+ testPassed . SetResult ( true ) ;
336
335
}
337
336
}
337
+ }
338
338
) ;
339
339
var messages = new List < ( ulong , Message ) > ( ) ;
340
340
for ( var i = 1 ; i <= NumberOfMessages ; i ++ )
@@ -386,9 +386,10 @@ public async Task ProducerSendsArrays255Bytes(ReadOnlySequence<byte> @event)
386
386
var testPassed = new TaskCompletionSource < bool > ( ) ;
387
387
var rawProducer = await system . CreateRawProducer ( new
388
388
RawProducerConfig ( stream )
389
- {
390
- Reference = "producer" , ConfirmHandler = _ => { testPassed . SetResult ( true ) ; }
391
- }
389
+ {
390
+ Reference = "producer" ,
391
+ ConfirmHandler = _ => { testPassed . SetResult ( true ) ; }
392
+ }
392
393
) ;
393
394
394
395
const ulong PublishingId = 0 ;
0 commit comments