@@ 146-153 (lines=8) @@ | ||
143 | */ |
|
144 | public function attach(EventManagerInterface $events, $priority = 1) |
|
145 | { |
|
146 | $callback = function (EntityEvent $event) { |
|
147 | $repository = $event->getTarget()->getRepository(); |
|
148 | ||
149 | $event->setResult(call_user_func_array( |
|
150 | [$repository, $event->getName()], |
|
151 | $event->getParams() |
|
152 | )); |
|
153 | }; |
|
154 | ||
155 | $this->listeners[] = $events->attach('countBy', $callback, 0); |
|
156 | $this->listeners[] = $events->attach('delete', $callback, 0); |
|
@@ 164-172 (lines=9) @@ | ||
161 | $this->listeners[] = $events->attach('findOneBy', $callback, 0); |
|
162 | $this->listeners[] = $events->attach( |
|
163 | 'persist', |
|
164 | function (EntityEvent $event) { |
|
165 | $repository = $event->getTarget()->getRepository(); |
|
166 | ||
167 | call_user_func_array([$repository, 'persist'], $event->getParams()); |
|
168 | ||
169 | if ($repository instanceof FlushableInterface) { |
|
170 | $repository->flush(); |
|
171 | } |
|
172 | }, |
|
173 | 0 |
|
174 | ); |
|
175 | $this->listeners[] = $events->attach( |