Th3Mouk\ReactiveEventDispatcher\Dispatcher::dispatch()

Complexity

Conditions	2
Paths	2

Size

Total Lines	14
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function dispatch(object $event)
    {
        $listeners = $this->listenerProvider->getListenersForEvent($event);

        $observable = Observable::of($event);

        foreach ($listeners as $listener) {
            \assert(\is_callable($listener));
            $observable = $observable
                ->flatMap($listener)
                ->mapTo($event);
        }

        return $observable;
    }