docs: async def open(self):
          """Register with the publisher."""
          self.store.register(self)
          while not self.finished:
              message = await self.messages.get()
              await self.publish(message)