async def METHOD_NAME(self) -> None:
    app = self.app
    async with app.agents:
        app.flow_control.resume()
        # Wait for agent to enter execution.
        await self.wait(self.agent_started, timeout=1.0)
        # Wait for Stream.__aiter__ to start up.
        await self.sleep(0.5)
        # Update indices and compile closures for agent delivery
        await self.conductor_setup(assigned=set(self.tps))
        # send first message
        await self.put(key=str(0).encode(), value=str(0).encode())
        # Wait for first message to be processed
        await self.wait(self.agent_started_processing, timeout=10.0)
        # send the rest of the messages
        for i in range(1, self.num_messages):
            await self.put(key=str(i).encode(), value=str(i).encode())
        # Wait for last message to be processed
        await self.wait(self.agent_stopped_processing, timeout=1000.0)
    self.finished.set()