ConcurrentEvents 1.12.5
An event system build on top of the concurrent futures library, including additional threading tools

ConcurrentEvents
================
.. image:: https://gitlab.com/Reggles44/concurrentevents/badges/master/pipeline.svg
    :alt: pipeline status
    :target: https://gitlab.com/Reggles44/concurrentevents/-/commits/master

.. image:: https://gitlab.com/Reggles44/concurrentevents/badges/master/coverage.svg
    :alt: coverage report
    :target: https://gitlab.com/Reggles44/concurrentevents/-/commits/master

.. image:: https://readthedocs.org/projects/concurrentevents/badge/?version=latest
    :target: https://concurrentevents.readthedocs.io/en/latest/?badge=latest
    :alt: Documentation Status

``ConcurrentEvents`` is a light weight event system and threading tools build around the concurrent futures library.

The aim of this project is to create an extremely simple and generic event system as well as tools to monitor and use it effectively.

The focus of this project is based around the ``ConcurrentEvents.EventManager``, ``ConcurrentEvents.EventHandler``, ``ConcurrentEvents.Event`` classes and ``ConcurrentEvents.Catch`` decorator to create a simple and safe way to do multi-threading through an event framework.

Installation
------------
``ConcurrentEvents`` should be installed through pip on ``python3.5`` or higher

.. code-block:: bash

    python -m pip install ConcurrentEvents
    
Usage
-----

ConcurrentEvents is used similar to other event systems where by decorators are used to map functions to events.
This simple example shows a hello world run through the event system but catching the `Start` event

.. code-block:: python

    from ConcurrentEvents import EventManager, catch, Start

    @catch(Start)
    def hello_world():
        print("Hello World")

    EventManager().start()

A more complicated example might involve having one event trigger more.
In the following example a custom `Event` is created to handle outputting counting.
Additionally the `CountingEventHandler` class is made as a subclass of `EventHandler` so that it can use the build in functionality of firing and canceling events.

.. code-block:: python

    from ConcurrentEvents import EventManager, EventHandler, catch, Start, Event

    class CountEvent(Event):
        pass

    class CountingEventHandler(EventHandler):
        @catch(Start)
        def start_counting(self):
            for i in range(10):
                self.fire(CountEvent(i))

        @catch(CountEvent)
        def print_count(self, i):
            print(i)

    EventManager().start()

Using the same example of counting there is also functionality to cancel an event or simply trigger exit.
The following code will cancel when `i` is equal to 5.
At the same time, if `i` is equal to 8 the exit event will fire which stops all functionality and goes to cleanup.

.. code-block:: python

    from ConcurrentEvents import EventManager, EventHandler, catch, Start, Event, Exit

    class CountEvent(Event):
        pass

    class CountingEventHandler(EventHandler):
        @catch(Start)
        def start_counting(self):
            for i in range(10):
                self.fire(CountEvent(i))
                if i == 5:
                    self.cancel()
                if i == 8:
                    self.fire(Exit())

        @catch(CountEvent)
        def print_count(self, i):
            print(i)

    EventManager().start()