pyventus_event_emitter_quickstart_with_decorator_subscription.py

1import asyncio
2from pyventus import EventLinker, EventEmitter
3
4# 1. Define the event handler using the EventLinker.on decorator
5@EventLinker.on("greet")
6def handle_greet(name: str):
7    print(f"Hello, {name}!")
8
9async def main():
10    # 2. Initialize the EventEmitter
11    # By default, it uses the SynchronousEventEmitter strategy
12    emitter = EventEmitter()
13
14    # 3. Emit the event
15    emitter.emit("greet", name="World")
16    
17    # Wait for any background tasks if necessary
18    await asyncio.sleep(0.1)
19
20if __name__ == "__main__":
21    asyncio.run(main())