docs: async def publish(self, message):
          """Pushes data to a listener."""
          try:
              self.write('data: {}\n\n'.format(message))
              await self.flush()
          except StreamClosedError:
              self.finished = True