<filename>events.py
__all__ = ['Event', 'EventDispatcher', 'EventListener', 'EventAPIException', 'EventDispatchManager']


from multiprocessing import Process, Pipe


class EventAPIException(Exception):
    pass


class Event:
    """
    __Abstract Interface Class.__\n
    Subclasses of `Event` must be `pickable` objects, and typically
    should only possess publically accessable members.
    """
    pass


class EventListener:
    """
    __Abstract Interface Class.__\n
    Listens to events dispatched by `EventDispatcher`s.\n
    Must be registered to `EventDispatcher`s which dispatch at least one event type
    that this listener subscribes to.\n
    __** _Parameters_ **__\n
    \tcallbacks:\t
    \t\tA Python `dict` which has sublclasses of `Event` as keys
    \t\tand a `callable` function reference as its values.
    """
    def __init__(self, callbacks={}):
        type_err = '`EventListener` constructor requires a dict of `Event`'\
                 + ' type as key and `callable` callback function as value.'
        if not isinstance(callbacks, dict):
            raise TypeError(type_err)
        for event_type in callbacks:
            if not callable(callbacks[event_type]) or not issubclass(event_type, Event):
                raise TypeError(type_err)
        self.event_callbacks = callbacks


class EventDispatcher:
    """
    __Abstract Interface Class.__\n
    Dispatches events for registered `EventListener`s.\n
    __** _Parameters_ **__\n
    \tevents:\t
    \t\tThe event types which this event will dispatch.\t
    \t\tMust be a subclass of `Event`.\t
    \n
    __** _Required Method Implementations_ **__:\n
    __update:__ _See documentation for details on implementation._\t
    __finish:__ _See documentation for details on implementation._\t
    \n
    __** _Optional Method Implementations_ **__:\n
    __init:__ _See documentation for details on implementation._
    """
    def __init__(self, *events):
        self.__is_deployed = False
        self.event_types = tuple(events)
        self.event_parent_conns = dict()
        self.event_child_conns = dict()
        self.listeners = dict()
        # Create pipes for triggering events
        for event_type in self.event_types:
            if not issubclass(event_type, Event):
                raise TypeError(str(type(event_type)) + ' is not of type ' + str(Event))
            # Establish 1-way connections for sending events
            self.event_parent_conns[event_type], self.event_child_conns[event_type] = Pipe(duplex=False)
            self.listeners[event_type] = set()
        # Establish 1-way connection between the parent and child process for issuing termination command
        self.__parent_conn, self.__child_conn = Pipe(duplex=True)
        self.process = None

    @property
    def is_deployed(self):
        return self.__is_deployed

    def deploy(self):
        """Start dispatcher process loop."""
        self.__is_deployed = True
        _args = (self.__parent_conn, self.event_child_conns)
        self.process = Process(target=self.__deploy, args=_args)
        self.process.start()

    def end(self):
        """Terminate the dispatcher process."""
        self.__parent_conn.send('terminate')
        self.process.terminate()
        while self.process.is_alive():
            continue
        self.__is_deployed = False

    def register(self, listener):
        if self.is_deployed:
            raise EventAPIException('Cannot register `EventListener` objects with a `EventDispatcher` that is currently deployed.')
        for event_type in listener.event_callbacks:
            if event_type in self.listeners:
                if not issubclass(type(listener), EventListener):
                    raise TypeError(str(listener) + ' is not of type ' + str(EventListener))
                if listener not in self.listeners[event_type]:
                    self.listeners[event_type].add(listener)

    def dispatch(self):
        """
        Dispatches events to registered listeners.
        """
        if not self.is_deployed:
            raise EventAPIException('`EventDispatcher` cannot dispatch events while not deployed.')
        for event_type in self.event_parent_conns:
            event = None
            # Flush old events from pipe
            while self.event_parent_conns[event_type].poll():
                event = self.event_parent_conns[event_type].recv()
            if event is not None:
                for listener in self.listeners[event_type]:
                    listener.event_callbacks[event_type](event)

    def init(self):
        """
        __**Optional abstract interface method**__\n
        Implement any initialization logic needed for your update function.\n
        __IMPORTANT:__\t
        Return a `tuple` of `args` and `dict` of `kwargs` from this function.
        These will be forwarded to the `update` and `end` methods.\n
        \tE.G.:
        \t  return (arg1, arg2), {'kwarg1': object, 'kwarg2': object}
        """
        return (), {}

    def update(self):
        """
        __**Required abstract interface method**__\n
        Implement the logic for creating events here.\t
        Return multiple events as an unpacked tuple.\n
        __IMPORTANT:__\t
        Objects initialized in the `init` method will be forwarded here as
        unpacked `args` and `kwargs`. This means _all objects_ returned
        as `args` and `kwargs` by `init` _must be_ parameters of this method,
        even if they remain unused in this method.
        """
        raise NotImplementedError('`update()` is abstract method that must be implemented per `EventDispatcher`.')

    def finish(self):
        """
        __**Required abstract interface method**__\n
        Implement any final logic that needs to run when the loop ends.\n
        __IMPORTANT:__\t
        Objects initialized in the `init` method will be forwarded here as
        unpacked `args` and `kwargs`. This means _all objects_ returned
        as `args` and `kwargs` by `init` _must be_ parameters of this method,
        even if they remain unused in this method.
        """
        raise NotImplementedError('`finish()` is abstract method that must be implemented per `EventDispatcher`.')

    def __deploy(self, command_conn, event_conns):
        """Dispatcher process loop."""
        args, kwargs = self.init()
        is_deployed = True
        try:
            while is_deployed:
                # Update and create events.
                events = self.update(*args, **kwargs)
                if not isinstance(events, tuple):
                    events = (events,)
                # Send events
                for event in events:
                    event_conns[type(event)].send(event)
                # Get communications from parent process
                if command_conn.poll():
                    cmd = command_conn.recv()
                    if cmd == 'terminate':
                        is_deployed = False
        finally:
            self.finish(*args, **kwargs)


class EventDispatchManager:
    """
    Manages `EventDispatcher` and `EventListener` objects.\n
    Dispatchers must be registered and deployed before the `invoke_dispatch` method will invoke
    dispatchers to dispatch events to registered listeners. `EventListener`s are automatically registered
    with all valid `EventDispatcher`s which dispatch at least one event type for which the `EventListener`
    subscribes to.\n
    __** _Parameters_ **__\n
    \tregistrees:
    \t\tThe `EventDispatcher`s and `EventListener`s to register
    \t\twith this `EventDispatcherManager` at object creation.
    """

    def __init__(self, *registrees):
        # check that registrees are subclass of either `EventDispatcher` or `EventListener`
        for reg in registrees:
            if not (issubclass(type(reg), EventDispatcher) or issubclass(type(reg), EventListener)):
                raise TypeError('Type {} is not subclass of type {} or {}'.format(type(reg), EventDispatcher, EventListener))
        self.__dispatchers = dict()
        self.__dispatchers_set = set()
        self.__disp_events_set = set()
        dispatchers = [dispatcher for dispatcher in registrees if issubclass(type(dispatcher), EventDispatcher)]
        listeners = [listener for listener in registrees if issubclass(type(listener), EventListener)]
        self.register_dispatcher(*dispatchers)
        self.register_listener(*listeners)

    def invoke_dispatch(self, event_type=None):
        """
        Invoke `dispatch` method of `EventDispatcher` objects.\n
        If `event_type` is `None`, all registered dispatchers will `dispatch` any events,
        otherwise the `dispatch` method of the registered dispatcher which dispatches
        events of type `event_type` will be called.\n
        __** _Parameters_ **__\n
        \tevent_type:  *optional*
        \t\tSpecifies the dispatcher for which to invoke `dispatch`.
        \t\tIf `None`, all registered dispatchers not
        \t\tyet deployed will be deployed.
        """
        if event_type is None:
            for dispatcher in self.__dispatchers_set:
                if dispatcher.is_deployed:
                    dispatcher.dispatch()
        else:
            if self.__dispatchers[event_type].is_deployed:
                dispatcher.dispatch()

    def register_dispatcher(self, *dispatchers):
        """
        Registers `EventDispatcher` objects.\n
        Attempting to register more than one dispatcher for the same event type will
        raise an `EventAPIException`.\n
        __** _Parameters_ **__\n
        \tdispatchers:  the `EventDispatcher` object(s) to register
        """
        for dispatcher in dispatchers:
            for event_type in dispatcher.event_types:
                if event_type not in self.__disp_events_set:
                    self.__disp_events_set.add(event_type)
                else:
                    raise EventAPIException('Cannont register multiple `EventDispatcher`s \
                                             for same event type {}.'.format(event_type))
            for event_type in dispatcher.event_types:
                self.__dispatchers[event_type] = dispatcher
            self.__dispatchers_set.add(dispatcher)

    def register_listener(self, *listeners):
        """
        Registers `EventListener` objects.\n
        __** _Parameters_ **__\n
        \tlisteners:   the `EventListener` object(s) to register
        """
        for listener in listeners:
            for event_type in listener.event_callbacks:
                self.__dispatchers[event_type].register(listener)

    def deploy_dispatchers(self, event_type=None):
        """
        Begins registered `EventDispatcher` object's process.\n
        If `event_type` is `None`, all registered dispatchers not yet deployed will be deployed.
        Otherwise the registered dispatcher which dispatches events of type `event_type`
        will be deployed.\n
        __** _Parameters_ **__\n
        \tevent_type:  *optional*
        \t\tSpecifies the dispatcher to deploy. If `None`,
        \t\tall registered dispatchers not yet deployed
        \t\twill be deployed.
        """
        if event_type is None:
            for dispatcher in self.__dispatchers.values():
                if not dispatcher.is_deployed:
                    dispatcher.deploy()
        else:
            if not self.__dispatchers[event_type].is_deployed:
                dispatcher.deploy()

    def end_dispatchers(self, event_type=None):
        """
        Ends registered `EventDispatcher` object's prcoess.\n
        If `event_type` is `None`, all registered dispatchers currently deployed will be terminated.
        Otherwise the registered dispatcher which dispatches events of type `event_type`
        will be terminated.\n
        __** _Parameters_ **__\n
        \tevent_type:  *optional*
        \t\tSpecifies the dispatcher to end. If `None`,
        \t\tall registered dispatchers currently deployed
        \t\twill be ended.
        """
        if event_type is None:
            for dispatcher in self.__dispatchers.values():
                if dispatcher.is_deployed:
                    dispatcher.end()
        else:
            if self.__dispatchers[event_type].is_deployed:
                dispatcher.end()

<filename>events.py
__all__ = ['Event', 'EventDispatcher', 'EventListener', 'EventAPIException', 'EventDispatchManager']


from multiprocessing import Process, Pipe


class EventAPIException(Exception):
    pass


class Event:
    """
    __Abstract Interface Class.__\n
    Subclasses of `Event` must be `pickable` objects, and typically
    should only possess publically accessable members.
    """
    pass


class EventListener:
    """
    __Abstract Interface Class.__\n
    Listens to events dispatched by `EventDispatcher`s.\n
    Must be registered to `EventDispatcher`s which dispatch at least one event type
    that this listener subscribes to.\n
    __** _Parameters_ **__\n
    \tcallbacks:\t
    \t\tA Python `dict` which has sublclasses of `Event` as keys
    \t\tand a `callable` function reference as its values.
    """
    def __init__(self, callbacks={}):
        type_err = '`EventListener` constructor requires a dict of `Event`'\
                 + ' type as key and `callable` callback function as value.'
        if not isinstance(callbacks, dict):
            raise TypeError(type_err)
        for event_type in callbacks:
            if not callable(callbacks[event_type]) or not issubclass(event_type, Event):
                raise TypeError(type_err)
        self.event_callbacks = callbacks


class EventDispatcher:
    """
    __Abstract Interface Class.__\n
    Dispatches events for registered `EventListener`s.\n
    __** _Parameters_ **__\n
    \tevents:\t
    \t\tThe event types which this event will dispatch.\t
    \t\tMust be a subclass of `Event`.\t
    \n
    __** _Required Method Implementations_ **__:\n
    __update:__ _See documentation for details on implementation._\t
    __finish:__ _See documentation for details on implementation._\t
    \n
    __** _Optional Method Implementations_ **__:\n
    __init:__ _See documentation for details on implementation._
    """
    def __init__(self, *events):
        self.__is_deployed = False
        self.event_types = tuple(events)
        self.event_parent_conns = dict()
        self.event_child_conns = dict()
        self.listeners = dict()
        # Create pipes for triggering events
        for event_type in self.event_types:
            if not issubclass(event_type, Event):
                raise TypeError(str(type(event_type)) + ' is not of type ' + str(Event))
            # Establish 1-way connections for sending events
            self.event_parent_conns[event_type], self.event_child_conns[event_type] = Pipe(duplex=False)
            self.listeners[event_type] = set()
        # Establish 1-way connection between the parent and child process for issuing termination command
        self.__parent_conn, self.__child_conn = Pipe(duplex=True)
        self.process = None

    @property
    def is_deployed(self):
        return self.__is_deployed

    def deploy(self):
        """Start dispatcher process loop."""
        self.__is_deployed = True
        _args = (self.__parent_conn, self.event_child_conns)
        self.process = Process(target=self.__deploy, args=_args)
        self.process.start()

    def end(self):
        """Terminate the dispatcher process."""
        self.__parent_conn.send('terminate')
        self.process.terminate()
        while self.process.is_alive():
            continue
        self.__is_deployed = False

    def register(self, listener):
        if self.is_deployed:
            raise EventAPIException('Cannot register `EventListener` objects with a `EventDispatcher` that is currently deployed.')
        for event_type in listener.event_callbacks:
            if event_type in self.listeners:
                if not issubclass(type(listener), EventListener):
                    raise TypeError(str(listener) + ' is not of type ' + str(EventListener))
                if listener not in self.listeners[event_type]:
                    self.listeners[event_type].add(listener)

    def dispatch(self):
        """
        Dispatches events to registered listeners.
        """
        if not self.is_deployed:
            raise EventAPIException('`EventDispatcher` cannot dispatch events while not deployed.')
        for event_type in self.event_parent_conns:
            event = None
            # Flush old events from pipe
            while self.event_parent_conns[event_type].poll():
                event = self.event_parent_conns[event_type].recv()
            if event is not None:
                for listener in self.listeners[event_type]:
                    listener.event_callbacks[event_type](event)

    def init(self):
        """
        __**Optional abstract interface method**__\n
        Implement any initialization logic needed for your update function.\n
        __IMPORTANT:__\t
        Return a `tuple` of `args` and `dict` of `kwargs` from this function.
        These will be forwarded to the `update` and `end` methods.\n
        \tE.G.:
        \t  return (arg1, arg2), {'kwarg1': object, 'kwarg2': object}
        """
        return (), {}

    def update(self):
        """
        __**Required abstract interface method**__\n
        Implement the logic for creating events here.\t
        Return multiple events as an unpacked tuple.\n
        __IMPORTANT:__\t
        Objects initialized in the `init` method will be forwarded here as
        unpacked `args` and `kwargs`. This means _all objects_ returned
        as `args` and `kwargs` by `init` _must be_ parameters of this method,
        even if they remain unused in this method.
        """
        raise NotImplementedError('`update()` is abstract method that must be implemented per `EventDispatcher`.')

    def finish(self):
        """
        __**Required abstract interface method**__\n
        Implement any final logic that needs to run when the loop ends.\n
        __IMPORTANT:__\t
        Objects initialized in the `init` method will be forwarded here as
        unpacked `args` and `kwargs`. This means _all objects_ returned
        as `args` and `kwargs` by `init` _must be_ parameters of this method,
        even if they remain unused in this method.
        """
        raise NotImplementedError('`finish()` is abstract method that must be implemented per `EventDispatcher`.')

    def __deploy(self, command_conn, event_conns):
        """Dispatcher process loop."""
        args, kwargs = self.init()
        is_deployed = True
        try:
            while is_deployed:
                # Update and create events.
                events = self.update(*args, **kwargs)
                if not isinstance(events, tuple):
                    events = (events,)
                # Send events
                for event in events:
                    event_conns[type(event)].send(event)
                # Get communications from parent process
                if command_conn.poll():
                    cmd = command_conn.recv()
                    if cmd == 'terminate':
                        is_deployed = False
        finally:
            self.finish(*args, **kwargs)


class EventDispatchManager:
    """
    Manages `EventDispatcher` and `EventListener` objects.\n
    Dispatchers must be registered and deployed before the `invoke_dispatch` method will invoke
    dispatchers to dispatch events to registered listeners. `EventListener`s are automatically registered
    with all valid `EventDispatcher`s which dispatch at least one event type for which the `EventListener`
    subscribes to.\n
    __** _Parameters_ **__\n
    \tregistrees:
    \t\tThe `EventDispatcher`s and `EventListener`s to register
    \t\twith this `EventDispatcherManager` at object creation.
    """

    def __init__(self, *registrees):
        # check that registrees are subclass of either `EventDispatcher` or `EventListener`
        for reg in registrees:
            if not (issubclass(type(reg), EventDispatcher) or issubclass(type(reg), EventListener)):
                raise TypeError('Type {} is not subclass of type {} or {}'.format(type(reg), EventDispatcher, EventListener))
        self.__dispatchers = dict()
        self.__dispatchers_set = set()
        self.__disp_events_set = set()
        dispatchers = [dispatcher for dispatcher in registrees if issubclass(type(dispatcher), EventDispatcher)]
        listeners = [listener for listener in registrees if issubclass(type(listener), EventListener)]
        self.register_dispatcher(*dispatchers)
        self.register_listener(*listeners)

    def invoke_dispatch(self, event_type=None):
        """
        Invoke `dispatch` method of `EventDispatcher` objects.\n
        If `event_type` is `None`, all registered dispatchers will `dispatch` any events,
        otherwise the `dispatch` method of the registered dispatcher which dispatches
        events of type `event_type` will be called.\n
        __** _Parameters_ **__\n
        \tevent_type:  *optional*
        \t\tSpecifies the dispatcher for which to invoke `dispatch`.
        \t\tIf `None`, all registered dispatchers not
        \t\tyet deployed will be deployed.
        """
        if event_type is None:
            for dispatcher in self.__dispatchers_set:
                if dispatcher.is_deployed:
                    dispatcher.dispatch()
        else:
            if self.__dispatchers[event_type].is_deployed:
                dispatcher.dispatch()

    def register_dispatcher(self, *dispatchers):
        """
        Registers `EventDispatcher` objects.\n
        Attempting to register more than one dispatcher for the same event type will
        raise an `EventAPIException`.\n
        __** _Parameters_ **__\n
        \tdispatchers:  the `EventDispatcher` object(s) to register
        """
        for dispatcher in dispatchers:
            for event_type in dispatcher.event_types:
                if event_type not in self.__disp_events_set:
                    self.__disp_events_set.add(event_type)
                else:
                    raise EventAPIException('Cannont register multiple `EventDispatcher`s \
                                             for same event type {}.'.format(event_type))
            for event_type in dispatcher.event_types:
                self.__dispatchers[event_type] = dispatcher
            self.__dispatchers_set.add(dispatcher)

    def register_listener(self, *listeners):
        """
        Registers `EventListener` objects.\n
        __** _Parameters_ **__\n
        \tlisteners:   the `EventListener` object(s) to register
        """
        for listener in listeners:
            for event_type in listener.event_callbacks:
                self.__dispatchers[event_type].register(listener)

    def deploy_dispatchers(self, event_type=None):
        """
        Begins registered `EventDispatcher` object's process.\n
        If `event_type` is `None`, all registered dispatchers not yet deployed will be deployed.
        Otherwise the registered dispatcher which dispatches events of type `event_type`
        will be deployed.\n
        __** _Parameters_ **__\n
        \tevent_type:  *optional*
        \t\tSpecifies the dispatcher to deploy. If `None`,
        \t\tall registered dispatchers not yet deployed
        \t\twill be deployed.
        """
        if event_type is None:
            for dispatcher in self.__dispatchers.values():
                if not dispatcher.is_deployed:
                    dispatcher.deploy()
        else:
            if not self.__dispatchers[event_type].is_deployed:
                dispatcher.deploy()

    def end_dispatchers(self, event_type=None):
        """
        Ends registered `EventDispatcher` object's prcoess.\n
        If `event_type` is `None`, all registered dispatchers currently deployed will be terminated.
        Otherwise the registered dispatcher which dispatches events of type `event_type`
        will be terminated.\n
        __** _Parameters_ **__\n
        \tevent_type:  *optional*
        \t\tSpecifies the dispatcher to end. If `None`,
        \t\tall registered dispatchers currently deployed
        \t\twill be ended.
        """
        if event_type is None:
            for dispatcher in self.__dispatchers.values():
                if dispatcher.is_deployed:
                    dispatcher.end()
        else:
            if self.__dispatchers[event_type].is_deployed:
                dispatcher.end()

__Abstract Interface Class.__\n     Subclasses of `Event` must be `pickable` objects, and typically     should only possess publically accessable members. __Abstract Interface Class.__\n     Listens to events dispatched by `EventDispatcher`s.\n     Must be registered to `EventDispatcher`s which dispatch at least one event type     that this listener subscribes to.\n     __** _Parameters_ **__\n     \tcallbacks:\t     \t\tA Python `dict` which has sublclasses of `Event` as keys     \t\tand a `callable` function reference as its values. __Abstract Interface Class.__\n     Dispatches events for registered `EventListener`s.\n     __** _Parameters_ **__\n     \tevents:\t     \t\tThe event types which this event will dispatch.\t     \t\tMust be a subclass of `Event`.\t     \n     __** _Required Method Implementations_ **__:\n     __update:__ _See documentation for details on implementation._\t     __finish:__ _See documentation for details on implementation._\t     \n     __** _Optional Method Implementations_ **__:\n     __init:__ _See documentation for details on implementation._ # Create pipes for triggering events # Establish 1-way connections for sending events # Establish 1-way connection between the parent and child process for issuing termination command Start dispatcher process loop. Terminate the dispatcher process. Dispatches events to registered listeners. # Flush old events from pipe __**Optional abstract interface method**__\n         Implement any initialization logic needed for your update function.\n         __IMPORTANT:__\t         Return a `tuple` of `args` and `dict` of `kwargs` from this function.         These will be forwarded to the `update` and `end` methods.\n         \tE.G.:         \t  return (arg1, arg2), {'kwarg1': object, 'kwarg2': object} __**Required abstract interface method**__\n         Implement the logic for creating events here.\t         Return multiple events as an unpacked tuple.\n         __IMPORTANT:__\t         Objects initialized in the `init` method will be forwarded here as         unpacked `args` and `kwargs`. This means _all objects_ returned         as `args` and `kwargs` by `init` _must be_ parameters of this method,         even if they remain unused in this method. __**Required abstract interface method**__\n         Implement any final logic that needs to run when the loop ends.\n         __IMPORTANT:__\t         Objects initialized in the `init` method will be forwarded here as         unpacked `args` and `kwargs`. This means _all objects_ returned         as `args` and `kwargs` by `init` _must be_ parameters of this method,         even if they remain unused in this method. Dispatcher process loop. # Update and create events. # Send events # Get communications from parent process Manages `EventDispatcher` and `EventListener` objects.\n     Dispatchers must be registered and deployed before the `invoke_dispatch` method will invoke     dispatchers to dispatch events to registered listeners. `EventListener`s are automatically registered     with all valid `EventDispatcher`s which dispatch at least one event type for which the `EventListener`     subscribes to.\n     __** _Parameters_ **__\n     \tregistrees:     \t\tThe `EventDispatcher`s and `EventListener`s to register     \t\twith this `EventDispatcherManager` at object creation. # check that registrees are subclass of either `EventDispatcher` or `EventListener` Invoke `dispatch` method of `EventDispatcher` objects.\n         If `event_type` is `None`, all registered dispatchers will `dispatch` any events,         otherwise the `dispatch` method of the registered dispatcher which dispatches         events of type `event_type` will be called.\n         __** _Parameters_ **__\n         \tevent_type:  *optional*         \t\tSpecifies the dispatcher for which to invoke `dispatch`.         \t\tIf `None`, all registered dispatchers not         \t\tyet deployed will be deployed. Registers `EventDispatcher` objects.\n         Attempting to register more than one dispatcher for the same event type will         raise an `EventAPIException`.\n         __** _Parameters_ **__\n         \tdispatchers:  the `EventDispatcher` object(s) to register Registers `EventListener` objects.\n         __** _Parameters_ **__\n         \tlisteners:   the `EventListener` object(s) to register Begins registered `EventDispatcher` object's process.\n         If `event_type` is `None`, all registered dispatchers not yet deployed will be deployed.         Otherwise the registered dispatcher which dispatches events of type `event_type`         will be deployed.\n         __** _Parameters_ **__\n         \tevent_type:  *optional*         \t\tSpecifies the dispatcher to deploy. If `None`,         \t\tall registered dispatchers not yet deployed         \t\twill be deployed. Ends registered `EventDispatcher` object's prcoess.\n         If `event_type` is `None`, all registered dispatchers currently deployed will be terminated.         Otherwise the registered dispatcher which dispatches events of type `event_type`         will be terminated.\n         __** _Parameters_ **__\n         \tevent_type:  *optional*         \t\tSpecifies the dispatcher to end. If `None`,         \t\tall registered dispatchers currently deployed         \t\twill be ended.