Enqueue an event for processing

async def trigger(self, event, kwargs):
        """ Enqueue an event for processing """
        await self._queue.put((event, kwargs))
        self._resume_processing.set()