feat: allow subscribe_event callback parameter take zero arguments

Author: sassanh

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Changelog
 
+## Version 0.9.14
+
+- feat: allow `subscribe_event` callback parameter take zero arguments
+
 ## Version 0.9.13
 
 - feat: make `subscribe` method of `autorun`'s return value, call its callback with

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "python-redux"
-version = "0.9.13"
+version = "0.9.14"
 description = "Redux implementation for Python"
 authors = ["Sassan Haradji <sassanh@gmail.com>"]
 license = "Apache-2.0"

redux/basic_types.py

@@ -27,7 +27,7 @@ class EventSubscriptionOptions(Immutable):
 SelectorOutput = TypeVar('SelectorOutput', infer_variance=True)
 ComparatorOutput = TypeVar('ComparatorOutput', infer_variance=True)
 Comparator = Callable[[State], ComparatorOutput]
-EventHandler = Callable[[Event], Any]
+EventHandler = Callable[[Event], Any] | Callable[[], Any]
 
 
 class CompleteReducerResult(Immutable, Generic[State, Action, Event]):

redux/main.py

@@ -81,7 +81,7 @@ class EventSubscriber(Protocol):
     def __call__(
         self: EventSubscriber,
         event_type: type[Event],
-        handler: Callable[[Event], Any],
+        handler: EventHandler[Event],
         options: EventSubscriptionOptions | None = None,
     ) -> Callable[[], None]:  # pyright: ignore[reportGeneralTypeIssues]
         ...
@@ -166,8 +166,10 @@ def run() -> None:
                     for event_handler, options in event_handlers[type(event)].copy():
                         if options.run_async:
                             event_handlers_queue.put((event_handler, event))
+                        elif len(signature(event_handler).parameters) == 1:
+                            cast(Callable[[Event], Any], event_handler)(event)
                         else:
-                            event_handler(event)
+                            cast(Callable[[], Any], event_handler)()
 
     def dispatch(*parameters: Action | Event | list[Action | Event]) -> None:
         items = [