@@ -54,7 +54,7 @@ |
||
54 | 54 | ->method('populate') |
55 | 55 | ->will( |
56 | 56 | $this->returnCallback( |
57 | - function () use ($provider) { |
|
57 | + function() use ($provider) { |
|
58 | 58 | $provider->index( |
59 | 59 | 'my_id', |
60 | 60 | ['foo' => 'bar'] |
@@ -73,7 +73,7 @@ |
||
73 | 73 | { |
74 | 74 | if ($this->isTagIncorrect($tag)) { |
75 | 75 | throw new \InvalidArgumentException( |
76 | - sprintf('DataProvider "%s" must specify the "index"'. |
|
76 | + sprintf('DataProvider "%s" must specify the "index"' . |
|
77 | 77 | ' and "type" attribute.', |
78 | 78 | $providerId |
79 | 79 | ) |
@@ -24,7 +24,7 @@ |
||
24 | 24 | |
25 | 25 | $loader = new Loader\YamlFileLoader( |
26 | 26 | $container, |
27 | - new FileLocator(__DIR__.'/../Resources/config') |
|
27 | + new FileLocator(__DIR__ . '/../Resources/config') |
|
28 | 28 | ); |
29 | 29 | |
30 | 30 | $loader->load('services.yml'); |
@@ -31,7 +31,7 @@ |
||
31 | 31 | { |
32 | 32 | $entries = $this->registry->get($index, $type); |
33 | 33 | |
34 | - foreach($entries as $entry) { |
|
34 | + foreach ($entries as $entry) { |
|
35 | 35 | $entry->getProvider()->run( |
36 | 36 | $client, |
37 | 37 | $entry->getIndex(), |
@@ -38,7 +38,7 @@ |
||
38 | 38 | { |
39 | 39 | return array_filter( |
40 | 40 | $this->entries, |
41 | - function ($entry) use ($index, $type) { |
|
41 | + function($entry) use ($index, $type) { |
|
42 | 42 | return $entry->match($index, $type); |
43 | 43 | } |
44 | 44 | ); |
@@ -97,7 +97,7 @@ discard block |
||
97 | 97 | |
98 | 98 | $dispatcher->addListener( |
99 | 99 | 'elasticsearch.has_started_handling', |
100 | - function (HasStartedHandling $event) use ($output) { |
|
100 | + function(HasStartedHandling $event) use ($output) { |
|
101 | 101 | $output->writeln(sprintf( |
102 | 102 | '<info>Start running <comment>%d</comment> providers</info>', |
103 | 103 | count($event->getEntries()) |
@@ -107,7 +107,7 @@ discard block |
||
107 | 107 | |
108 | 108 | $dispatcher->addListener( |
109 | 109 | 'elasticsearch.has_started_providing', |
110 | - function (HasStartedProviding $event) use ($output) { |
|
110 | + function(HasStartedProviding $event) use ($output) { |
|
111 | 111 | $output->writeln(sprintf( |
112 | 112 | '<info>Start running <comment>%s</comment> provider</info>', |
113 | 113 | get_class($event->getEntry()->getProvider()) |
@@ -117,7 +117,7 @@ discard block |
||
117 | 117 | |
118 | 118 | $dispatcher->addListener( |
119 | 119 | 'elasticsearch.has_indexed_document', |
120 | - function (HasIndexingDocument $event) use ($output) { |
|
120 | + function(HasIndexingDocument $event) use ($output) { |
|
121 | 121 | $output->writeln(sprintf( |
122 | 122 | '<info>Indexing <comment>%s</comment> document</info>', |
123 | 123 | get_class($event->getEntry()->getId()) |