| @@ -40,7 +40,7 @@ | ||
| 40 | 40 | */ | 
| 41 | 41 | public function handle($message, callable $next) | 
| 42 | 42 |      { | 
| 43 | -        $this->queue[] = Delegate::fromClosure(function () use ($message, $next) { | |
| 43 | +        $this->queue[] = Delegate::fromClosure(function() use ($message, $next) { | |
| 44 | 44 | return $next($message); | 
| 45 | 45 | }); | 
| 46 | 46 | |
| @@ -154,7 +154,7 @@ discard block | ||
| 154 | 154 | } | 
| 155 | 155 | } | 
| 156 | 156 | |
| 157 | -        $next = Delegate::fromClosure(function ($message) { | |
| 157 | +        $next = Delegate::fromClosure(function($message) { | |
| 158 | 158 | // the final middleware return the same message | 
| 159 | 159 | return $message; | 
| 160 | 160 | }); | 
| @@ -162,7 +162,7 @@ discard block | ||
| 162 | 162 | // reverse iteration over middlewares | 
| 163 | 163 | /** @var MiddlewareInterface $middleware */ | 
| 164 | 164 |          while ($middleware = array_pop($middlewares)) { | 
| 165 | -            $next = Delegate::fromClosure(function ($message) use ($middleware, $next) { | |
| 165 | +            $next = Delegate::fromClosure(function($message) use ($middleware, $next) { | |
| 166 | 166 | return $middleware->handle($message, $next); | 
| 167 | 167 | }); | 
| 168 | 168 | } | 
| @@ -29,7 +29,7 @@ discard block | ||
| 29 | 29 | $this | 
| 30 | 30 | ->given($middleware = new LockingMiddleware()) | 
| 31 | 31 | ->then() | 
| 32 | -                ->exception(function () use ($middleware) { | |
| 32 | +                ->exception(function() use ($middleware) { | |
| 33 | 33 | new Bus([$middleware, new \StdClass()]); | 
| 34 | 34 | }) | 
| 35 | 35 | ->isInstanceOf(InvalidMiddlewareException::class) | 
| @@ -69,7 +69,7 @@ discard block | ||
| 69 | 69 | ->given($middleware = new LockingMiddleware()) | 
| 70 | 70 | ->and($bus = new Bus()) | 
| 71 | 71 | ->then() | 
| 72 | -                ->exception(function () use ($bus, $middleware) { | |
| 72 | +                ->exception(function() use ($bus, $middleware) { | |
| 73 | 73 | $bus->addMiddlewareBefore($middleware, $middleware); | 
| 74 | 74 | })->isInstanceOf(\InvalidArgumentException::class) | 
| 75 | 75 | ; | 
| @@ -93,7 +93,7 @@ discard block | ||
| 93 | 93 | ->given($middleware = new LockingMiddleware()) | 
| 94 | 94 | ->and($bus = new Bus()) | 
| 95 | 95 | ->then() | 
| 96 | -                ->exception(function () use ($bus, $middleware) { | |
| 96 | +                ->exception(function() use ($bus, $middleware) { | |
| 97 | 97 | $bus->addMiddlewareAfter($middleware, $middleware); | 
| 98 | 98 | })->isInstanceOf(\InvalidArgumentException::class) | 
| 99 | 99 | ; | 
| @@ -41,14 +41,14 @@ | ||
| 41 | 41 | ) | 
| 42 | 42 | ->and($middleware = new MessageHandlerMiddleware($resolver)) | 
| 43 | 43 |              ->and($command = new LoginUserMessage('[email protected]', 'plainpassword')) | 
| 44 | -            ->and($callable = function (LoginUserMessage $command) { | |
| 44 | +            ->and($callable = function(LoginUserMessage $command) { | |
| 45 | 45 |                  $command->setEmail('[email protected]'); | 
| 46 | 46 | }) | 
| 47 | 47 | ->when($middleware->handle($command, $callable)) | 
| 48 | 48 | ->then() | 
| 49 | 49 | ->string($command->email()) | 
| 50 | 50 |                      ->isEqualTo('[email protected]') | 
| 51 | -                ->exception(function () use ($middleware, $callable) { | |
| 51 | +                ->exception(function() use ($middleware, $callable) { | |
| 52 | 52 | $middleware->handle(new \StdClass(), $callable); | 
| 53 | 53 | })->isInstanceOf(\InvalidArgumentException::class) | 
| 54 | 54 | ; | 
| @@ -31,7 +31,7 @@ discard block | ||
| 31 | 31 | $this | 
| 32 | 32 | ->given($middleware = new LockingMiddleware()) | 
| 33 | 33 |              ->and($event = new LoginUserMessage('[email protected]')) | 
| 34 | -            ->and($callable = function (LoginUserMessage $event) { | |
| 34 | +            ->and($callable = function(LoginUserMessage $event) { | |
| 35 | 35 |                  $event->setEmail('[email protected]'); | 
| 36 | 36 | }) | 
| 37 | 37 | ->when($middleware->handle($event, $callable)) | 
| @@ -43,13 +43,13 @@ discard block | ||
| 43 | 43 | $this | 
| 44 | 44 | ->given($middleware = new LockingMiddleware()) | 
| 45 | 45 |              ->and($event = new LoginUserMessage('[email protected]')) | 
| 46 | -            ->and($callable = function (LoginUserMessage $event) { | |
| 46 | +            ->and($callable = function(LoginUserMessage $event) { | |
| 47 | 47 |                  $event->setEmail('[email protected]'); | 
| 48 | 48 | |
| 49 | 49 | throw new \InvalidArgumentException(); | 
| 50 | 50 | }) | 
| 51 | 51 | ->then() | 
| 52 | -                ->exception(function () use ($middleware, $event, $callable) { | |
| 52 | +                ->exception(function() use ($middleware, $event, $callable) { | |
| 53 | 53 | $middleware->handle($event, $callable); | 
| 54 | 54 | }) | 
| 55 | 55 | ->isInstanceOf(\InvalidArgumentException::class) | 
| @@ -57,12 +57,12 @@ discard block | ||
| 57 | 57 | |
| 58 | 58 | $this | 
| 59 | 59 | ->given($middleware = new LockingMiddleware()) | 
| 60 | -            ->and($callable = function (LoginUserMessage $event) { | |
| 60 | +            ->and($callable = function(LoginUserMessage $event) { | |
| 61 | 61 | $event->setEmail(md5($event->email())); | 
| 62 | 62 | }) | 
| 63 | 63 | ->and($listener = new TriggerMessageOnListener($middleware, $callable)) | 
| 64 | 64 |              ->and($event = new LoginUserMessage('[email protected]')) | 
| 65 | -            ->when($middleware->handle($event, function ($event) use ($listener) { | |
| 65 | +            ->when($middleware->handle($event, function($event) use ($listener) { | |
| 66 | 66 | $listener->onLogin($event); | 
| 67 | 67 | })) | 
| 68 | 68 | ->then() | 
| @@ -30,7 +30,7 @@ | ||
| 30 | 30 | /** | 
| 31 | 31 | * LoginUserMessage constructor. | 
| 32 | 32 | * | 
| 33 | - * @param $email | |
| 33 | + * @param string $email | |
| 34 | 34 | */ | 
| 35 | 35 | public function __construct($email) | 
| 36 | 36 |      { | 
| @@ -29,7 +29,7 @@ | ||
| 29 | 29 | /** | 
| 30 | 30 | * LogoutUserMessage constructor. | 
| 31 | 31 | * | 
| 32 | - * @param $email | |
| 32 | + * @param string $email | |
| 33 | 33 | */ | 
| 34 | 34 | public function __construct($email) | 
| 35 | 35 |      { | 
| @@ -40,11 +40,11 @@ discard block | ||
| 40 | 40 | $this | 
| 41 | 41 | ->given($handler = new LoginUserMessageListener()) | 
| 42 | 42 | ->then() | 
| 43 | -                ->exception(function () use ($handler) { | |
| 43 | +                ->exception(function() use ($handler) { | |
| 44 | 44 | new InMemoryLocator([255 => $handler]); | 
| 45 | 45 | }) | 
| 46 | 46 | ->isInstanceOf(\InvalidArgumentException::class) | 
| 47 | -                ->exception(function () use ($handler) { | |
| 47 | +                ->exception(function() use ($handler) { | |
| 48 | 48 | new InMemoryLocator([LoginUserMessage::class => 255]); | 
| 49 | 49 | }) | 
| 50 | 50 | ->isInstanceOf(\InvalidArgumentException::class) | 
| @@ -64,7 +64,7 @@ discard block | ||
| 64 | 64 | ->then() | 
| 65 | 65 | ->object($result) | 
| 66 | 66 | ->isEqualTo($handler) | 
| 67 | -                ->exception(function () use ($locator) { | |
| 67 | +                ->exception(function() use ($locator) { | |
| 68 | 68 |                      $locator->locate('Foo'); | 
| 69 | 69 | }) | 
| 70 | 70 | ->isInstanceOf(NotFoundException::class) | 
| @@ -38,7 +38,7 @@ | ||
| 38 | 38 | $this | 
| 39 | 39 | ->given($resolver = new FromMessageNamedResolver()) | 
| 40 | 40 | ->then() | 
| 41 | -                ->exception(function () use ($resolver) { | |
| 41 | +                ->exception(function() use ($resolver) { | |
| 42 | 42 |                      $resolver->resolve(new LoginUserMessage('[email protected]', 'plainpassword')); | 
| 43 | 43 | }) | 
| 44 | 44 | ->isInstanceOf(\InvalidArgumentException::class) |