Struct ApiClient 

pub struct ApiClient { /* private fields */ }

Lightweight API HTTP client.

Implementations

impl ApiClient

pub fn new(token: impl Into<String>) -> Self

Create a new client with the given token.

pub fn with_client(token: impl Into<String>, client: Client) -> Self

pub fn with_base_url(self, base: impl Into<String>) -> Self

Replace base URL (builder style).

pub fn with_token(self, token: impl Into<String>) -> Self

Replace token (builder style).

pub fn with_timeout(self, t: Duration) -> Self

Set optional timeout for non-streaming requests.

pub async fn send(&self, req: ApiRequest) -> Result<ChatCompletionResponse>

Send a non-streaming request and parse the full ChatCompletionResponse.

pub async fn send_stream( &self, req: ApiRequest, ) -> Result<BoxStream<'_, Result<ChatCompletionChunk, ApiError>>>

Send a streaming (SSE) request and return a BoxStream of parsed ChatCompletionChunks.

The stream borrows &self via the response lifetime, so it cannot outlive the client. Use into_stream when you need a 'static stream (e.g. inside a state machine that owns the client).

pub async fn into_stream( self, req: ApiRequest, ) -> Result<BoxStream<'static, Result<ChatCompletionChunk, ApiError>>>

Send a streaming (SSE) request, consuming self, and return a 'static BoxStream of parsed ChatCompletionChunks.

Taking ownership of the client means the returned stream is not tied to any borrow, making it suitable for storage inside a state machine (e.g. AgentStream).

pub async fn stream_text( &self, req: ApiRequest, ) -> Result<BoxStream<'_, Result<String, ApiError>>>

Convenience: stream only text fragments (delta.content) as String items.

Each yielded item is Result<String, ApiError>.

Trait Implementations

impl Clone for ApiClient

fn clone(&self) -> ApiClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ApiClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.