Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory :  /home/corals/demo.cartinsight.co/vendor/livewire/livewire/src/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

<?php

namespace Livewire;

class EventBus
{
    protected $listeners = [];
    protected $listenersAfter = [];
    protected $listenersBefore = [];

    function boot()
    {
        app()->singleton($this::class);
    }

    function on($name, $callback) {
        if (! isset($this->listeners[$name])) $this->listeners[$name] = [];

        $this->listeners[$name][] = $callback;

        return fn() => $this->off($name, $callback);
    }

    function before($name, $callback) {
        if (! isset($this->listenersBefore[$name])) $this->listenersBefore[$name] = [];

        $this->listenersBefore[$name][] = $callback;

        return fn() => $this->off($name, $callback);
    }

    function after($name, $callback) {
        if (! isset($this->listenersAfter[$name])) $this->listenersAfter[$name] = [];

        $this->listenersAfter[$name][] = $callback;

        return fn() => $this->off($name, $callback);
    }

    function off($name, $callback) {
        $index = array_search($callback, $this->listeners[$name] ?? []);
        $indexAfter = array_search($callback, $this->listenersAfter[$name] ?? []);
        $indexBefore = array_search($callback, $this->listenersBefore[$name] ?? []);

        if ($index !== false) unset($this->listeners[$name][$index]);
        elseif ($indexAfter !== false) unset($this->listenersAfter[$name][$indexAfter]);
        elseif ($indexBefore !== false) unset($this->listenersBefore[$name][$indexBefore]);
    }

    function trigger($name, ...$params) {
        $middlewares = [];

        $listeners = array_merge(
            ($this->listenersBefore[$name] ?? []),
            ($this->listeners[$name] ?? []),
            ($this->listenersAfter[$name] ?? []),
        );

        foreach ($listeners as $callback) {
            $result = $callback(...$params);

            if ($result) {
                $middlewares[] = $result;
            }
        }

        return function (&$forward = null, ...$extras) use ($middlewares) {
            foreach ($middlewares as $finisher) {
                if ($finisher === null) continue;

                $finisher = is_array($finisher) ? last($finisher) : $finisher;

                $result = $finisher($forward, ...$extras);

                // Only overwrite previous "forward" if something is returned from the callback.
                $forward = $result ?? $forward;
            }

            return $forward;
        };
    }
}