EVNTDispatch 0.0.0

A Python event system

EVNTDispatch

EVNTDispatch is a versatile Python library designed to facilitate event-driven programming by providing a flexible event dispatcher. Whether you are building a graphical user interface, a command-line application, or a complex system with asynchronous components, the Event System simplifies communication and coordination between different parts of your code.

Key Features

• Event Dispatching: Easily define and dispatch events to notify components of changes or user interactions.

• Asynchronous Support: Seamlessly integrate asynchronous event listeners for efficient handling of time-consuming tasks without blocking the main execution.

• Priority and Max Responders: Control the order of event listener execution and limit the number of responders for fine-grained control over event handling.

• Task Scheduling: Schedule tasks to be executed after a specified delay, adding a layer of automation to your application.

Basic Async Example

import asyncio

from event_system.event_dispatcher import EventDispatcher, PEvent, EventType

dispatcher = EventDispatcher()


async def process_message(event: PEvent):
    message_data, user_id = event.data
    # Simulate processing the message, e.g., storing it in a database or applying business logic
    print(f"Processing Message from User {user_id}: {message_data}")
    await asyncio.sleep(1)
    print("Message Processed")


async def send_message(user_id: int, message: str):
    await dispatcher.async_trigger(PEvent("new_message", EventType.Base, data=(message, user_id)))


async def main():
    dispatcher.start()

    dispatcher.add_listener("new_message", process_message)

    # Simulate users sending messages
    task = [send_message(1, "Hello, how are you?"),
            send_message(2, "I'm doing well, thanks!"),
            send_message(1, "What's new?"),
            send_message(3, "Not much, just relaxing.")
            ]
    await asyncio.gather(*task)

    await dispatcher.close()


if __name__ == "__main__":
    asyncio.run(main())

License

This project is licensed under the MIT License.