def handles()

in message_flow/events/subscriber/domain_event_handler.py [0:0]

• 6 lines of code
• 2 McCabe index (conditional complexity)

    def handles(self, message: IMessage) -> bool:
        return self._aggregate_type == message.get_required_header(
            EventMessageHeaders.AGGREGATE_TYPE
        ) and self._event_class.__name__ == message.get_required_header(
            EventMessageHeaders.EVENT_TYPE
        )