Struct ResponseHandler 

pub struct ResponseHandler<T> { /* private fields */ }

One-shot async response handler. Exactly one of the successful/failed handlers passed to an API call is consumed.

Implementations

impl<T> ResponseHandler<T>

pub fn new<F, Fut>(handler: F) -> Self

where F: FnOnce(ResponseHandlerInput) -> Fut + Send + 'static, Fut: Future<Output = Result<ResponseHandlerOutput<T>, AiMuxError>> + Send + 'static,

Create a handler from an async closure.

pub fn streaming(self) -> Self

Mark the handler as streaming: it hands the response body onward as a stream instead of reading it to completion, so the per-exchange response timeout must not cover body consumption.

pub async fn handle( self, input: ResponseHandlerInput, ) -> Result<ResponseHandlerOutput<T>, AiMuxError>

Consume the handler and process one response.

Errors

Returns the handler’s contextual API, parse, or caller-abort failure.