async def send(self, *args, **kwargs):
        """Send args and kwargs to all registered callbacks"""
        for callback in self:
            res = callback(*args, **kwargs)
            if asyncio.iscoroutine(res) or isinstance(res, asyncio.Future):
                await res
async def send ( self , * args , ** kwargs ) : for callback in self : res = callback ( * args , ** kwargs ) if asyncio . iscoroutine ( res ) or isinstance ( res , asyncio . Future ) : await res
Send args and kwargs to all registered callbacks