Searched refs:poll_fill_buf (Results 1 - 4 of 4) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A D	async_buf_read.rs	37 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>>; in poll_fill_buf() functions 43 /// [`Self::poll_fill_buf`] in order to function properly. in poll_fill_buf() 46 /// [`Self::poll_fill_buf`] in poll_fill_buf() 52 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf() functions 53 Pin::new(&mut **self.get_mut()).poll_fill_buf(cx) in poll_fill_buf() 63 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf() functions 64 Pin::new(&mut **self.get_mut()).poll_fill_buf(cx) in poll_fill_buf() 78 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf() functions 79 self.get_mut().as_mut().poll_fill_buf(cx) in poll_fill_buf()
H A D	read_task.rs	301 let available = poll_ready!(Pin::new(&mut reader).poll_fill_buf(cx))?; in poll_read_until()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/
H A D	async_buf_reader.rs	191 let rem = poll_ready!(self.as_mut().poll_fill_buf(cx))?; in poll_read() 201 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<std::io::Result<&[u8]>> { in poll_fill_buf() functions
H A D	async_buf_writer.rs	319 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf() functions 321 unsafe { Pin::new_unchecked(&mut this.inner).poll_fill_buf(cx) }

Completed in 3 milliseconds

Indexes created Thu Nov 07 10:32:03 CST 2024