pub struct HttpCaller { /* private fields */ }Implementations§
Source§impl HttpCaller
impl HttpCaller
pub fn new() -> Result<Self, Error>
pub async fn call_openai( &self, model: &str, api_key: &str, request: &ChatRequest, ) -> Result<ChatResponse, HyperInferError>
pub async fn call_anthropic( &self, model: &str, api_key: &str, request: &ChatRequest, ) -> Result<ChatResponse, HyperInferError>
Sourcepub fn stream_openai(
&self,
model: &str,
api_key: &str,
request: &ChatRequest,
) -> Pin<Box<dyn Stream<Item = Result<ChatChunk, HyperInferError>> + Send + 'static>>
pub fn stream_openai( &self, model: &str, api_key: &str, request: &ChatRequest, ) -> Pin<Box<dyn Stream<Item = Result<ChatChunk, HyperInferError>> + Send + 'static>>
Stream chat completions from OpenAI via SSE.
Returns a pinned Stream of ChatChunk items. The stream ends after
the provider sends the [DONE] sentinel or the connection closes.
Sourcepub fn stream_anthropic(
&self,
model: &str,
api_key: &str,
request: &ChatRequest,
) -> Pin<Box<dyn Stream<Item = Result<ChatChunk, HyperInferError>> + Send + 'static>>
pub fn stream_anthropic( &self, model: &str, api_key: &str, request: &ChatRequest, ) -> Pin<Box<dyn Stream<Item = Result<ChatChunk, HyperInferError>> + Send + 'static>>
Stream chat completions from Anthropic via SSE.
Anthropic uses a different event schema: content_block_delta events
carry text deltas; message_delta carries the final usage.
Auto Trait Implementations§
impl !RefUnwindSafe for HttpCaller
impl !UnwindSafe for HttpCaller
impl Freeze for HttpCaller
impl Send for HttpCaller
impl Sync for HttpCaller
impl Unpin for HttpCaller
impl UnsafeUnpin for HttpCaller
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more