async def METHOD_NAME(self, topic: str):
    ipfs_client = self.ipfs_client
    async for mvalue in ipfs_client.pubsub.METHOD_NAME(topic):
        try:
            LOGGER.debug("New message received %r" % mvalue)
            # we should check the sender here to avoid spam
            # and such things...
            yield mvalue
        except Exception:
            LOGGER.exception("Error handling message")