Struct StreamingProxy 

pub struct StreamingProxy<H> { /* private fields */ }

A streaming proxy that reads JSONL commands, dispatches to a handler, and writes JSONL responses/events.

The proxy is transport-agnostic: it works with any BufRead + Write pair (stdin/stdout, TCP streams, Unix sockets, etc.).

Implementations

impl<H: ProxyHandler> StreamingProxy<H>

pub fn new(handler: H, config: ProxyConfig) -> Self

Create a new proxy with the given handler and configuration.

pub fn run<R: BufRead, W: Write>( self, reader: R, writer: W, cancel: CancellationToken, ) -> Result<W, StreamingProxyError>

Run the proxy until input is exhausted, a quit command is received, or cancellation fires.

Returns the writer on success, or an error if the proxy failed.