code: 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
docs: Send args and kwargs to all registered callbacks