@@ -496,11 +496,7 @@ public function testShouldCallOnIdleExtensionMethod()
496
496
->expects ($ this ->once ())
497
497
->method ('onIdle ' )
498
498
->with ($ this ->isInstanceOf (Context::class))
499
- ->willReturnCallback (function (Context $ context ) use (
500
- $ contextStub ,
501
- $ consumerStub ,
502
- $ processorMock
503
- ) {
499
+ ->willReturnCallback (function (Context $ context ) use ($ contextStub ) {
504
500
$ this ->assertSame ($ contextStub , $ context ->getPsrContext ());
505
501
$ this ->assertInstanceOf (NullLogger::class, $ context ->getLogger ());
506
502
$ this ->assertNull ($ context ->getPsrProcessor ());
@@ -535,12 +531,7 @@ public function testShouldCallOnBeforeReceiveExtensionMethod()
535
531
->expects ($ this ->once ())
536
532
->method ('onBeforeReceive ' )
537
533
->with ($ this ->isInstanceOf (Context::class))
538
- ->willReturnCallback (function (Context $ context ) use (
539
- $ contextStub ,
540
- $ consumerStub ,
541
- $ processorMock ,
542
- $ queue
543
- ) {
534
+ ->willReturnCallback (function (Context $ context ) use ($ contextStub ) {
544
535
$ this ->assertSame ($ contextStub , $ context ->getPsrContext ());
545
536
$ this ->assertInstanceOf (NullLogger::class, $ context ->getLogger ());
546
537
$ this ->assertNull ($ context ->getPsrProcessor ());
@@ -711,11 +702,7 @@ public function testShouldAllowInterruptConsumingOnIdle()
711
702
->expects ($ this ->once ())
712
703
->method ('onInterrupted ' )
713
704
->with ($ this ->isInstanceOf (Context::class))
714
- ->willReturnCallback (function (Context $ context ) use (
715
- $ contextStub ,
716
- $ consumerStub ,
717
- $ processorMock
718
- ) {
705
+ ->willReturnCallback (function (Context $ context ) use ($ contextStub ) {
719
706
$ this ->assertSame ($ contextStub , $ context ->getPsrContext ());
720
707
$ this ->assertInstanceOf (NullLogger::class, $ context ->getLogger ());
721
708
$ this ->assertNull ($ context ->getPsrConsumer ());
@@ -1222,7 +1209,7 @@ public function testShouldCallProcessorAsMessageComeAlong()
1222
1209
->expects ($ this ->any ())
1223
1210
->method ('onPreReceived ' )
1224
1211
->with ($ this ->isInstanceOf (Context::class))
1225
- ->willReturnCallback (function (Context $ context ) use ($ processorMock , $ queue1 , &$ actualContexts ) {
1212
+ ->willReturnCallback (function (Context $ context ) use (&$ actualContexts ) {
1226
1213
$ actualContexts [] = clone $ context ;
1227
1214
})
1228
1215
;
0 commit comments