Method publish

experiments/broadcast/server.py:33–36

(self, value)

        self.waiter = asyncio.get_running_loop().create_future()

    def publish(self, value):
        waiter = self.waiter
        self.waiter = asyncio.get_running_loop().create_future()
        waiter.set_result((value, self.waiter))

    async def subscribe(self):
        waiter = self.waiter