Searched refs:poll_ready (Results 1 – 8 of 8) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| H A D | async_buf_writer.rs | 20 use crate::io::{poll_ready, AsyncBufRead, AsyncRead, AsyncSeek, AsyncWrite, ReadBuf};
179 match poll_ready!( in flush()
212 poll_ready!(self.as_mut().flush(cx))?; in poll_write()
235 poll_ready!(self.as_mut().flush(cx))?; in poll_write_vectored()
256 poll_ready!(self.as_mut().flush(cx))?; in poll_write_vectored()
283 poll_ready!(self.as_mut().flush(cx))?; in poll_flush()
289 poll_ready!(self.as_mut().flush(cx))?; in poll_shutdown()
301 poll_ready!(self.as_mut().flush(cx))?; in poll_seek()
|
| H A D | async_buf_reader.rs | 21 use crate::io::{poll_ready, AsyncRead, AsyncSeek, AsyncWrite, ReadBuf};
191 let rem = poll_ready!(self.as_mut().poll_fill_buf(cx))?; in poll_read()
206 poll_ready!(Pin::new_unchecked(&mut this.inner).poll_read(cx, &mut read_buf))?; in poll_fill_buf()
231 poll_ready!(Pin::new_unchecked(&mut this.inner) in poll_seek()
238 poll_ready!(Pin::new_unchecked(&mut this.inner) in poll_seek()
245 let res = unsafe { poll_ready!(Pin::new_unchecked(&mut this.inner).poll_seek(cx, pos))? }; in poll_seek()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | mod.rs | 44 macro_rules! poll_ready { macro
53 pub(crate) use poll_ready;
|
| H A D | read_task.rs | 25 use crate::io::poll_ready;
215 let res = poll_ready!(poll_read_to_end(buf, *reader, read_len, cx)); in poll()
301 let available = poll_ready!(Pin::new(&mut reader).poll_fill_buf(cx))?; in poll_read_until()
370 let res = poll_ready!(poll_read_until(buf, *reader, b'\n', read_len, cx)); in poll()
404 let res = poll_ready!(poll_read_until(buf, reader, delim, read_len, cx))?; in poll_next()
457 let io_res = poll_ready!(poll_read_until(buf, reader, b'\n', read_len, cx)); in poll_next_line()
460 let res = poll_ready!(io_string_result(io_res, str_res, *read_len, output))?; in poll_next_line()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| H A D | mod.rs | 45 macro_rules! poll_ready { macro
54 pub(crate) use poll_ready;
|
| H A D | async_file.rs | 24 use crate::fs::{async_op, poll_ready};
72 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll()
78 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll()
406 let res = poll_ready!(Pin::new(state).poll(cx)); in poll_seek()
463 let (mut file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll_read()
472 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll_read()
481 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll_read()
559 let res = poll_ready!(Pin::new(state).poll(cx)); in poll_flush()
|
| H A D | async_dir.rs | 26 use crate::fs::{async_op, poll_ready};
579 let (std_dir, mut block) = poll_ready!(Pin::new(handle).poll(cx))?; in poll_next()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | async_source.rs | 27 use crate::io::{poll_ready, ReadBuf};
105 pub(crate) fn poll_ready(
126 let ready = poll_ready!(self.poll_ready(cx, interest))?;
|