from pykka import ThreadingActor

GetInfo = object()
ApiRequestListEvents = object()


class EventActor(ThreadingActor):
    def __init__(self, event_id):
        ThreadingActor.__init__(self)
        self.event_id = event_id

    def on_receive(self, message):
        if message is GetInfo:
            return f"My event id is {self.event_id}"


class ManagerActor(ThreadingActor):
    def __init__(self):
        ThreadingActor.__init__(self)
        self.events = [
            EventActor.start(event_id=i)
            for i in range(3)
        ]

    def on_receive(self, message):
        if message is ApiRequestListEvents:
            return self.events[0].ask(GetInfo, block=False).join(
                *[self.events[i].ask(GetInfo, block=False) for i in [1, 2]]
            )


class RootActor(ThreadingActor):
    def __init__(self):
        ThreadingActor.__init__(self)
        self.manager_actor = ManagerActor.start()

    def on_receive(self, message):
        if message is ApiRequestListEvents:
            return self.manager_actor.ask(ApiRequestListEvents, block=False)


root = RootActor.start()
f = root.ask(ApiRequestListEvents)