openai4s/kernel/sink_drain.py

• truncation_marker · function · L68-L75 — def truncation_marker(cap: int) -> str
• _StreamDrain · class · L78-L206 — class _StreamDrain
• init · method · L88-L110 — def init( self, path: str, *, cap: int, on_text: Callable[[str], None] | None = None, ) -> None
• retained · method · L113-L115 — def retained(self) -> int
• dropped · method · L118-L120 — def dropped(self) -> int
• _run · method · L122-L152 — def _run(self) -> None
• _absorb · method · L154-L175 — def _absorb(self, chunk: bytes) -> None
• finish · method · L177-L187 — def finish(self, timeout: float) -> str
• close · method · L189-L206 — def close(self) -> None
• SinkCapture · class · L209-L261 — class SinkCapture
• init · method · L212-L227 — def init( self, out_path: str, err_path: str, *, cap: int, on_chunk: Callable[[str], None] | None = None, ) -> None
• finish · method · L229-L230 — def finish(self, timeout: float = _FINISH_GRACE_SECONDS * 2) -> tuple[str, str]
• counters · method · L232-L250 — def counters(self) -> dict[str, int]
• close · method · L252-L261 — def close(self) -> None
• SinkDirectory · class · L264-L316 — class SinkDirectory
• init · method · L274-L283 — def init(self, temp_dir: str | None = None) -> None
• open · method · L285-L310 — def open( self, *, cap: int, on_chunk: Callable[[str], None] | None = None ) -> SinkCapture
• close · method · L312-L316 — def close(self) -> None: # self.root is ours either way — when the sandbox supplied the parent # we still made the sinks/ directory inside it, so removing it takes # only what we put there.