Home
last modified time | relevance | path

Searched refs:async_impl (Results 1 – 25 of 62) sorted by relevance

123

/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Dhttp_body.rs20 use ylong_http::body::async_impl::Body;
27 use crate::async_impl::interceptor::Interceptors;
550 use ylong_http::body::async_impl;
552 use crate::async_impl::interceptor::IdleInterceptor;
553 use crate::async_impl::HttpBody;
589 let res = async_impl::Body::trailer(&mut chunk) in async_chunk_trailer_1()
647 let res = async_impl::Body::trailer(&mut chunk) in async_chunk_trailer_2()
835 let read = async_impl::Body::data(&mut until_close, &mut buf) in http_body_until_close()
839 let read = async_impl::Body::data(&mut until_close, &mut buf) in http_body_until_close()
843 let read = async_impl::Body::data(&mut until_close, &mut buf) in http_body_until_close()
[all …]
H A Dtimeout.rs70 use crate::async_impl::interceptor::IdleInterceptor;
71 use crate::async_impl::timeout::TimeoutFuture;
72 use crate::async_impl::HttpBody;
97 Ok(crate::async_impl::Response::new(Response::from_raw_parts( in ut_timeout_future()
103 Result::<crate::async_impl::Response, HttpClientError>::Err( in ut_timeout_future()
H A Dresponse.rs16 use ylong_http::body::async_impl::Body;
19 use crate::async_impl::HttpBody;
H A Dclient.rs21 use crate::async_impl::dns::{DefaultDnsResolver, Resolver};
22 use crate::async_impl::interceptor::{IdleInterceptor, Interceptor, Interceptors};
23 use crate::async_impl::request::Message;
911 use crate::async_impl::{Body, Request, Response};
912 use crate::async_impl::{Client, HttpConnector};
933 use crate::async_impl::interceptor::IdleInterceptor; in client_request_redirect()
934 use crate::async_impl::{ClientBuilder, HttpBody}; in client_request_redirect()
1152 use crate::async_impl::ClientBuilder; in ut_client_builder_default()
H A Drequest.rs22 use ylong_http::body::async_impl::ReusableReader;
27 use crate::async_impl::interceptor::Interceptors;
429 use crate::async_impl::{Body, PercentEncoder, RequestBuilder};
/ohos5.0/commonlibrary/rust/ylong_http/docs/
H A Duser_guide.md32 用户可以使用 `ylong_http_client::async_impl::Client` 来生成一个异步 HTTP 客户端。该功能被 feature `async` 控制。
37 use ylong_http_client::async_impl::Client;
48 use ylong_http_client::async_impl::Client;
112 use ylong_http_client::async_impl::{Multipart, Part};
135 use ylong_http_client::async_impl::Uploader;
147 use ylong_http_client::async_impl::{Uploader, UploadOperator};
175 use ylong_http_client::async_impl::Client;
194 use ylong_http_client::async_impl::Body;
215 use ylong_http_client::async_impl::{Downloader, HttpBody, Response};
231 use ylong_http_client::async_impl::{Downloader, DownloadOperatorResponse};
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/tests/
H A Dsdv_async_https_pinning.rs82 let client = ylong_http_client::async_impl::Client::builder() in sdv_client_public_key_pinning()
131 let client = ylong_http_client::async_impl::Client::builder() in sdv_client_public_key_pinning()
180 let client = ylong_http_client::async_impl::Client::builder() in sdv_client_public_key_pinning()
264 let client = ylong_http_client::async_impl::Client::builder() in sdv_client_public_key_pinning_error()
272 let request = ylong_http_client::async_impl::Request::builder() in sdv_client_public_key_pinning_error()
276 .body(ylong_http_client::async_impl::Body::slice("hello")) in sdv_client_public_key_pinning_error()
H A Dsdv_async_http_proxy.rs19 use ylong_http::body::async_impl::Body;
59 let client = ylong_http_client::async_impl::Client::builder() in sdv_async_client_send_request()
H A Dsdv_async_http_body_io.rs19 use ylong_http::body::async_impl::Body;
20 use ylong_http_client::async_impl::Client;
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/
H A Dmod.rs49 pub use async_impl::ReusableReader;
174 pub mod async_impl { module
522 pub struct FromAsyncBody<T: super::async_impl::Body> {
526 impl<T: super::async_impl::Body> FromAsyncBody<T> {
532 impl<T: super::async_impl::Body> Deref for FromAsyncBody<T> {
540 impl<T: super::async_impl::Body> DerefMut for FromAsyncBody<T> {
585 use crate::body::async_impl::Body; in asyn_body_mut_asyn_body_data()
H A Dempty.rs18 use crate::body::{async_impl, sync_impl};
91 impl async_impl::Body for EmptyBody {
148 use crate::body::async_impl::Body; in empty_body_async_impl_data()
H A Dtext.rs20 use super::{async_impl, sync_impl};
192 impl<'c> async_impl::Body for TextBody<FromBytes<'c>> {
212 impl<T: AsyncRead + Unpin + Send + Sync> async_impl::Body for TextBody<FromAsyncReader<T>> {
531 use crate::body::async_impl::Body; in text_body_from_bytes_asyn_data()
594 use crate::body::async_impl::Body; in text_body_from_async_reader_asyn_data()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/
H A Dmod.rs20 use crate::async_impl::connector::ConnInfo;
21 use crate::async_impl::request::Message;
22 use crate::async_impl::Response;
H A Dhttp1.rs18 use ylong_http::body::async_impl::Body;
26 use crate::async_impl::connector::ConnInfo;
27 use crate::async_impl::interceptor::Interceptors;
28 use crate::async_impl::request::Message;
29 use crate::async_impl::{HttpBody, Request, Response};
H A Dhttp2.rs29 use crate::async_impl::conn::StreamData;
30 use crate::async_impl::request::Message;
31 use crate::async_impl::{HttpBody, Response};
381 use crate::async_impl::conn::http2::build_headers_frame;
453 use crate::async_impl::conn::http2::TextIo; in ut_http2_body_poll_read()
/ohos5.0/commonlibrary/rust/ylong_http/
H A DREADME_zh.md35 - `async_impl`：异步的 HTTP 客户端实现，该客户端实现需要使用 Rust 的异步运行时组件。异步 HTTP 客户端利用 Rust 的异步能力，具有优异的性能表现。
38 `sync_impl` 和 `async_impl` 接口原型基本一致（主要是 Rust 异步语法与同步语法的差异），所以用户可以在较小的代码改动量下完成同步和异步逻辑的切换。
40 `sync_impl` 和 `async_impl` 的整体架构相同，分为如下模块：
100 │ ├── async_impl # ylong_http_client 异步客户端实现
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/tests/
H A Dsdv_http_body.rs16 use ylong_http::body::{async_impl, ChunkBody, ChunkBodyDecoder, EmptyBody};
90 size = async_impl::Body::data(&mut task, buf.as_mut_slice()) in sdv_async_chunk_body_from_async_reader()
117 size = async_impl::Body::data(&mut task, buf.as_mut_slice()) in sdv_async_chunk_body_from_bytes()
211 use ylong_http::body::async_impl::Body as AsyncBody; in sdv_empty_body_async_impl_data()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/
H A Dmod.rs24 use crate::async_impl::Response;
261 use crate::async_impl::conn::StreamData;
262 use crate::async_impl::interceptor::IdleInterceptor;
263 use crate::async_impl::{Downloader, HttpBody, Response as adpater_resp};
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/
H A Dmod.rs26 use crate::async_impl::dns::{DefaultDnsResolver, EyeBallConfig, HappyEyeballs, Resolver};
134 use crate::async_impl::connector::stream::HttpStream;
135 use crate::async_impl::interceptor::{ConnDetail, ConnProtocol};
187 use crate::async_impl::connector::stream::HttpStream;
188 use crate::async_impl::interceptor::{ConnDetail, ConnProtocol};
189 use crate::async_impl::ssl_stream::{AsyncSslStream, MixStream};
416 use crate::async_impl::connector::tls::CreateTunnelErr;
459 use crate::async_impl::connector::tcp_stream;
460 use crate::async_impl::connector::tls::{other_io_error, tunnel, CreateTunnelErr};
461 use crate::async_impl::dns::{EyeBallConfig, HappyEyeballs};
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/
H A Dpart.rs19 use crate::body::async_impl::Body;
22 use crate::body::{async_impl, sync_impl, MimePart};
189 impl async_impl::Body for MimePartEncoder<'_> {
242 use crate::body::{async_impl, sync_impl, MimePart, MimePartEncoder};
H A Dmulti.rs20 use crate::body::{async_impl, sync_impl, MimeMulti, MimePartEncoder, TokenStatus, XPart};
308 impl async_impl::Body for MimeMultiEncoder<'_> {
370 use crate::body::{async_impl, sync_impl, MimeMulti, MimeMultiEncoder, MimePart};
600 async_impl::Body::data(&mut multi_encoder, &mut buf) in mime_multi_encoder_data_many_parts_nesting_then_async_data()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/examples/
H A Dmimebody_multi_then_async_data.rs16 use ylong_http::body::{async_impl, MimeMulti, MimeMultiEncoder, MimePart};
110 let len = async_impl::Body::data(&mut multi_encoder, &mut buf) in main()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/tests/common/
H A Dasync_utils.rs223 let client = ylong_http_client::async_impl::Client::builder()
281 let client = ylong_http_client::async_impl::Client::new();
337 let request = ylong_http_client::async_impl::Request::builder()
341 .body(ylong_http_client::async_impl::Body::slice($req_body))
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/
H A Dmix.rs19 use crate::body::async_impl::{self, DataFuture};
190 impl async_impl::Body for MixFrom<'_> {
221 use crate::body::{async_impl, sync_impl};
320 … let size = async_impl::Body::data(&mut mix, &mut buf).await.expect("MixFrom encode failed");
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/
H A Dmod.rs23 use ylong_http::body::async_impl::ReusableReader;
206 use crate::async_impl::uploader::{Context, Pin, Poll};
207 use crate::async_impl::{UploadOperator, Uploader, UploaderBuilder};

123