Method write

src/cli_core/structured_io.py:189–196

(self, event: HeadlessEvent | dict[str, Any])

        self._stream = stream if stream is not None else sys.stdout

    def write(self, event: HeadlessEvent | dict[str, Any]) -> None:
        payload = event.to_dict() if isinstance(event, HeadlessEvent) else dict(event)
        line = ndjson_safe_dumps(payload)
        self._stream.write(line + "\n")
        try:
            self._stream.flush()
        except Exception:
            pass

    def write_many(self, events: Iterable[HeadlessEvent | dict[str, Any]]) -> None:
        for event in events: