Source code for jivago.event.dispatch.message_dispatcher_function

from typing import Callable

from jivago.event.dispatch.message_dispatcher import MessageDispatcher
from jivago.lang.annotations import Override


class MessageDispatcherFunction(MessageDispatcher):

    def __init__(self, message_name: str, function: Callable):
        super().__init__(message_name)
        self.function = function

    @Override
    def handle(self, payload: object):
        if self._requires_payload_parameter():
            return self.function(payload)
        return self.function()

    def _requires_payload_parameter(self) -> bool:
        return self.function.__code__.co_argcount == 1