@@ -51,8 +51,8 @@ |
||
51 | 51 | protected function configure() |
52 | 52 | { |
53 | 53 | $this->setName('graphql:mercure:start') |
54 | - ->setDescription('Start mercure HUB server. Define mercure settings using env variables with MERCURE_* prefix in your .env file') |
|
55 | - ->addArgument('mercure', InputArgument::REQUIRED, 'Mercure binary'); |
|
54 | + ->setDescription('Start mercure HUB server. Define mercure settings using env variables with MERCURE_* prefix in your .env file') |
|
55 | + ->addArgument('mercure', InputArgument::REQUIRED, 'Mercure binary'); |
|
56 | 56 | } |
57 | 57 | |
58 | 58 | /** |
@@ -79,7 +79,7 @@ |
||
79 | 79 | $subscribersByTopics = []; |
80 | 80 | |
81 | 81 | $process->run( |
82 | - static function ($type, $msg) use ($output, &$subscribersByTopics, $subscriptionManager) { |
|
82 | + static function($type, $msg) use ($output, &$subscribersByTopics, $subscriptionManager) { |
|
83 | 83 | $output->writeln($msg); |
84 | 84 | |
85 | 85 | $connected = strpos($msg, '"New subscriber"') !== false; |
@@ -100,7 +100,7 @@ discard block |
||
100 | 100 | |
101 | 101 | array_walk_recursive( |
102 | 102 | $data, |
103 | - function (&$value, $key) { |
|
103 | + function(&$value, $key) { |
|
104 | 104 | if (is_object($value)) { |
105 | 105 | throw new \RuntimeException( |
106 | 106 | sprintf('The object "%s" in key "%s" can\'t be part of publish data, only scalar values can be sent.', get_class($value), $key) |
@@ -121,7 +121,7 @@ discard block |
||
121 | 121 | $channels = array_keys($this->registry->getEndpoint()->getSubscriptionsResolvers()); |
122 | 122 | $this->pubSubHandler->consume( |
123 | 123 | $channels, |
124 | - function (SubscriptionMessage $message) use ($output, $debug) { |
|
124 | + function(SubscriptionMessage $message) use ($output, $debug) { |
|
125 | 125 | /** @var Request $request */ |
126 | 126 | $request = $message->getMeta()['request'] ?? null; |
127 | 127 | $subscribedFilters = $message->getMeta()['arguments'] ?? []; |
@@ -169,7 +169,7 @@ discard block |
||
169 | 169 | { |
170 | 170 | array_walk_recursive( |
171 | 171 | $data, |
172 | - function (&$value) { |
|
172 | + function(&$value) { |
|
173 | 173 | if ($value instanceof NodeInterface) { |
174 | 174 | $value = IDEncoder::encode($value); |
175 | 175 | } |
@@ -59,11 +59,11 @@ |
||
59 | 59 | $container->registerForAutoconfiguration(InputFieldTypeGuesser::class)->addTag('graphql.input_type_guesser'); |
60 | 60 | $container->registerForAutoconfiguration(FilterResolverInterface::class)->addTag('graphql.filter_resolver'); |
61 | 61 | $container->registerForAutoconfiguration(SearchByInterface::class) |
62 | - ->addTag('graphql.list_search') |
|
63 | - ->setPublic(true); |
|
62 | + ->addTag('graphql.list_search') |
|
63 | + ->setPublic(true); |
|
64 | 64 | $container->registerForAutoconfiguration(FilterInterface::class) |
65 | - ->addTag('graphql.list_filter') |
|
66 | - ->setPublic(true); |
|
65 | + ->addTag('graphql.list_filter') |
|
66 | + ->setPublic(true); |
|
67 | 67 | } |
68 | 68 | |
69 | 69 | /** |
@@ -46,7 +46,7 @@ discard block |
||
46 | 46 | if ($formBuilder) { |
47 | 47 | $formBuilder->addEventListener( |
48 | 48 | FormEvents::SUBMIT, |
49 | - function (FormEvent $event) use (&$mutationEvent) { |
|
49 | + function(FormEvent $event) use (&$mutationEvent) { |
|
50 | 50 | if ($this->eventDispatcher) { |
51 | 51 | $mutationEvent = new GraphQLMutationEvent($this->context, $event); |
52 | 52 | $this->eventDispatcher->dispatch(GraphQLEvents::MUTATION_SUBMITTED, $mutationEvent); |
@@ -56,8 +56,8 @@ discard block |
||
56 | 56 | |
57 | 57 | $formBuilder->addEventSubscriber($this); |
58 | 58 | |
59 | - $extensionExecutor = function ($method) { |
|
60 | - return function (FormEvent $event) use ($method) { |
|
59 | + $extensionExecutor = function($method) { |
|
60 | + return function(FormEvent $event) use ($method) { |
|
61 | 61 | foreach ($this->extensions as $extension) { |
62 | 62 | call_user_func_array([$extension, $method], [$event]); |
63 | 63 | } |