Struct HttpAdapter 

pub struct HttpAdapter { /* private fields */ }

HTTP 适配器

提供高级 HTTP 请求功能，包括流式响应处理

Implementations

impl HttpAdapter

pub fn new() -> Self

创建新的 HTTP 适配器

pub fn with_config(config: HttpConfig) -> Self

创建带配置的 HTTP 适配器

pub fn abort_flag(&self) -> Arc<AtomicBool>

获取中断标志

pub fn abort(&self)

请求中断

pub fn reset(&self)

重置中断标志

pub fn is_aborted(&self) -> bool

检查是否已中断

pub async fn request(&self, request: HttpRequest) -> Result<Response>

执行 HTTP 请求

pub async fn request_stream( &self, request: HttpRequest, ) -> Result<HttpResponseStream>

执行流式 HTTP 请求

pub async fn request_sse(&self, request: HttpRequest) -> Result<SseStream>

执行 SSE 流式请求

Trait Implementations

impl Default for HttpAdapter

fn default() -> Self

Returns the “default value” for a type.

impl HttpAdapterTrait for HttpAdapter

fn get<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

执行 HTTP GET 请求

fn post<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, body: Value, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

执行 HTTP POST 请求

fn post_stream<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, body: Value, ) -> Pin<Box<dyn Future<Output = Result<HttpResponseStream>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

执行流式 HTTP POST 请求

fn post_sse<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, body: Value, ) -> Pin<Box<dyn Future<Output = Result<SseStream>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

执行 SSE 流式请求