Searched refs:consume (Results 1 - 7 of 7) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A D	async_buf_read.rs	36 /// [`Self::consume`] method to function properly. 47 fn consume(self: Pin<&mut Self>, amt: usize); in poll_fill_buf() functions 56 fn consume(mut self: Pin<&mut Self>, amt: usize) { in poll_fill_buf() functions 57 Pin::new(&mut **self).consume(amt) in poll_fill_buf() 67 fn consume(mut self: Pin<&mut Self>, amt: usize) { in poll_fill_buf() functions 68 Pin::new(&mut **self).consume(amt) in poll_fill_buf() 82 fn consume(self: Pin<&mut Self>, amt: usize) { in poll_fill_buf() functions 83 self.get_mut().as_mut().consume(amt) in poll_fill_buf()
H A D	read_task.rs	316 Pin::new(&mut reader).consume(used); in poll_read_until()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/
H A D	core.rs	40 AsyncHandle::CurrentThread(_) => Ok(consumer.consume(par_iter)), 85 return Ok(consumer.consume(par_iter)); 91 return Ok(consumer.consume(left)); 162 return Ok(consumer.consume(par_iter)); 168 return Ok(consumer.consume(left));
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/pariter/
H A D	for_each.rs	42 fn consume(&self, par_iter: P) -> Self::Output { in consume() functions
H A D	sum.rs	37 fn consume(&self, par_iter: P) -> Self::Output { in consume() functions
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/
H A D	async_buf_writer.rs	324 fn consume(self: Pin<&mut Self>, amt: usize) { in consume() functions 326 unsafe { Pin::new_unchecked(&mut this.inner).consume(amt) } in consume()
H A D	async_buf_reader.rs	194 self.as_mut().consume(r_len); in poll_read() 214 fn consume(self: Pin<&mut Self>, amt: usize) { in consume() functions

Completed in 4 milliseconds

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