Function outbound

src/entrypoints/agent_server_cli.py:140–147

Agent → stdout: one JSON object per line, flushed.

()

    out = sys.stdout

    async def outbound() -> None:
        """Agent → stdout: one JSON object per line, flushed."""
        async for msg in agent.messages_from_agent():
            try:
                out.write(json.dumps(msg) + "\n")
                out.flush()
            except (BrokenPipeError, OSError):
                return

    # Inbound: a daemon thread reads stdin lines and dispatches them onto the
    # loop (mirrors the existing threaded pattern). stdin EOF resolves `closed`.