| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | async_read.rs | 24 pub trait AsyncRead { interface
49 impl<T: AsyncRead + Unpin + ?Sized> AsyncRead for Box<T> {
60 impl<T: AsyncRead + Unpin + ?Sized> AsyncRead for &mut T { impl
71 impl<T> AsyncRead for Pin<T>
74 T::Target: AsyncRead,
90 pub trait AsyncReadExt: AsyncRead {
209 impl AsyncRead for &[u8] { impl
223 impl<R: AsyncRead + ?Sized> AsyncReadExt for R {}
|
| H A D | async_buf_read.rs | 20 use crate::io::AsyncRead;
26 pub trait AsyncBufRead: AsyncRead {
|
| H A D | read_task.rs | 24 use crate::io::async_read::AsyncRead;
57 R: AsyncRead + Unpin,
97 fn poll_read_to_end<R: AsyncRead + Unpin>( in poll_read_to_end()
135 R: AsyncRead + Unpin,
207 R: AsyncRead + Unpin,
242 R: AsyncRead + Unpin,
|
| H A D | stdin.rs | 19 use crate::io::{AsyncRead, ReadBuf, State};
45 impl AsyncRead for Stdin {
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http1.rs | 31 use crate::runtime::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt, ReadBuf};
42 S: AsyncRead + AsyncWrite + ConnInfo + Sync + Send + Unpin + 'static, in request()
98 S: AsyncRead + AsyncWrite + Sync + Send + Unpin + 'static, in encode_various_body()
142 S: AsyncRead + AsyncWrite + ConnInfo + Sync + Send + Unpin + 'static, in encode_request_part()
176 S: AsyncRead + AsyncWrite + ConnInfo + Sync + Send + Unpin + 'static, in decode_response()
230 S: AsyncRead + AsyncWrite + Sync + Send + Unpin + 'static, in encode_body()
280 impl<S: AsyncRead + Unpin> AsyncRead for Http1Conn<S> {
290 impl<S: AsyncRead + Unpin> StreamData for Http1Conn<S> {
|
| H A D | mod.rs | 24 use crate::runtime::{AsyncRead, AsyncWrite};
27 pub(crate) trait StreamData: AsyncRead {
36 S: AsyncRead + AsyncWrite + ConnInfo + Sync + Send + Unpin + 'static, in request()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| H A D | async_buf_reader.rs | 21 use crate::io::{poll_ready, AsyncRead, AsyncSeek, AsyncWrite, ReadBuf};
40 impl<R: AsyncRead> AsyncBufReader<R> {
180 impl<R: AsyncRead> AsyncRead for AsyncBufReader<R> {
200 impl<R: AsyncRead> AsyncBufRead for AsyncBufReader<R> {
220 impl<R: AsyncRead + AsyncSeek> AsyncSeek for AsyncBufReader<R> {
251 impl<R: AsyncRead + AsyncWrite> AsyncWrite for AsyncBufReader<R> {
|
| H A D | async_buf_writer.rs | 20 use crate::io::{poll_ready, AsyncBufRead, AsyncRead, AsyncSeek, AsyncWrite, ReadBuf};
307 impl<W: AsyncWrite + AsyncRead> AsyncRead for AsyncBufWriter<W> {
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | stream.rs | 20 use crate::runtime::{AsyncRead, AsyncWrite, ReadBuf};
37 impl<T> AsyncRead for HttpStream<T>
39 T: AsyncRead + AsyncWrite + Unpin,
53 T: AsyncRead + AsyncWrite + Unpin,
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/ |
| H A D | mod.rs | 27 use tokio::io::{AsyncRead, ReadBuf};
96 impl<R: AsyncRead + Unpin> Uploader<R, Console> {
126 impl<R, T> AsyncRead for Uploader<R, T>
128 R: AsyncRead + Unpin,
172 R: AsyncRead + Send + Sync + Unpin + 'static,
|
| H A D | builder.rs | 18 use tokio::io::AsyncRead;
61 pub fn reader<R: AsyncRead>(self, reader: R) -> UploaderBuilder<WantsOperator<R>> { in reader()
103 impl<R: AsyncRead> UploaderBuilder<WantsOperator<R>> {
|
| H A D | multipart.rs | 20 use tokio::io::{AsyncRead, ReadBuf};
191 impl AsyncRead for MultiPart {
370 pub fn stream<T: AsyncRead + Send + Sync + 'static>(mut self, body: T) -> Self { in stream()
443 Stream(Pin<Box<dyn AsyncRead + Send + Sync>>),
451 fn stream(reader: Pin<Box<dyn AsyncRead + Send + Sync>>) -> Self { in stream()
456 impl AsyncRead for MultiPartStates {
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| H A D | mix.rs | 18 use crate::runtime::{AsyncRead, AsyncWrite, ReadBuf};
28 impl<T> AsyncRead for MixStream<T>
30 T: AsyncRead + AsyncWrite + Unpin,
47 T: AsyncRead + AsyncWrite + Unpin,
|
| H A D | c_ssl_stream.rs | 20 use crate::runtime::{AsyncRead, AsyncWrite, ReadBuf};
57 S: AsyncRead + AsyncWrite,
88 impl<S> AsyncRead for AsyncSslStream<S>
90 S: AsyncRead + AsyncWrite,
124 S: AsyncRead + AsyncWrite,
|
| H A D | wrapper.rs | 19 use crate::runtime::{AsyncRead, AsyncWrite, ReadBuf};
44 S: AsyncRead,
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| H A D | mod.rs | 181 use crate::{AsyncRead, ReadBuf};
405 pub trait ReusableReader: AsyncRead + Sync {
444 use crate::AsyncRead;
497 pub struct FromAsyncReader<T: AsyncRead + Unpin + Send + Sync> {
501 impl<T: AsyncRead + Unpin + Send + Sync> FromAsyncReader<T> {
507 impl<T: AsyncRead + Unpin + Send + Sync> Deref for FromAsyncReader<T> {
515 impl<T: AsyncRead + Unpin + Send + Sync> DerefMut for FromAsyncReader<T> {
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/ |
| H A D | split.rs | 22 use ylong_runtime::io::{AsyncRead, AsyncWrite, ReadBuf};
53 T: AsyncRead + AsyncWrite, in split()
70 impl<T: AsyncRead> AsyncRead for Reader<T> {
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| H A D | builder.rs | 16 use crate::runtime::AsyncRead;
62 pub fn reader<R: AsyncRead>(self, reader: R) -> UploaderBuilder<WantsOperator<R>> { in reader()
104 impl<R: AsyncRead> UploaderBuilder<WantsOperator<R>> {
|
| H A D | mod.rs | 26 use crate::runtime::{AsyncRead, ReadBuf};
126 impl<R, T> AsyncRead for Uploader<R, T>
204 use ylong_runtime::io::AsyncRead;
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/ |
| H A D | lib.rs | 50 io::{AsyncRead, AsyncReadExt, AsyncSeekExt, ReadBuf},
55 io::{AsyncRead, AsyncReadExt, AsyncSeekExt, ReadBuf},
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/ |
| H A D | pty.rs | 22 use crate::io::{AsyncRead, AsyncWrite, ReadBuf};
178 impl AsyncRead for Pty {
228 impl AsyncRead for BorrowReadPty<'_> {
287 impl AsyncRead for SplitReadPty {
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| H A D | lib.rs | 85 io::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt, ReadBuf},
92 io::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt, ReadBuf},
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | child.rs | 22 use crate::io::{AsyncRead, AsyncReadExt, AsyncWrite, ReadBuf};
284 async fn read_to_end<T: AsyncRead + Unpin>(io: &mut Option<T>) -> io::Result<Vec<u8>> { in output_wait()
371 impl AsyncRead for ChildStdout {
381 impl AsyncRead for ChildStderr {
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | output.rs | 25 use crate::runtime::{AsyncRead, BoundedSender, ReadBuf, ReadHalf, SendError};
51 impl<S: AsyncRead + Unpin + Sync + Send + 'static> Future for RecvData<S> {
60 impl<S: AsyncRead + Unpin + Sync + Send + 'static> RecvData<S> {
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| H A D | simple.rs | 23 use crate::{AsyncRead, ReadBuf};
204 impl AsyncRead for MultiPart {
482 impl AsyncRead for MultiPartStates {
727 use ylong_runtime::io::{AsyncRead, ReadBuf}; in multipart_poll_data()
777 use ylong_runtime::io::{AsyncRead, ReadBuf}; in multipart_poll_data_stream()
|