Searched refs:poll_read (Results 1 - 25 of 25) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A D	async_read.rs	41 fn poll_read( in poll_read() functions 50 fn poll_read( in poll_read() functions 55 Pin::new(&mut **self).poll_read(cx, buf) in poll_read() 61 fn poll_read( in poll_read() functions 66 Pin::new(&mut **self).poll_read(cx, buf) in poll_read() 76 fn poll_read( in poll_read() functions 81 self.get_mut().as_mut().poll_read(cx, buf) in poll_read() 210 fn poll_read( in poll_read() functions
H A D	stdin.rs	46 fn poll_read( in poll_read() functions
H A D	read_task.rs	65 match Pin::new(&mut reader).poll_read(cx, &mut buf) { 115 let poll = Pin::new(&mut reader).poll_read(cx, &mut read_buf); in poll_read_to_end() 255 let _ = match Pin::new(&mut reader).poll_read(cx, &mut this.buf) {
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A D	mix.rs	35 // poll_read separately. 36 fn poll_read( in poll_read() functions 42 MixStream::Http(s) => Pin::new(s).poll_read(cx, buf), in poll_read() 43 MixStream::Https(s) => Pin::new(s).poll_read(cx, buf), in poll_read()
H A D	request.rs	358 fn poll_read( in poll_read() functions 368 return Pin::new(slice).poll_read(cx, buf); in poll_read() 372 BodyKind::Stream(ref mut stream) => Pin::new(stream).poll_read(cx, buf), in poll_read() 373 BodyKind::Multipart(ref mut multipart) => Pin::new(multipart).poll_read(cx, buf), in poll_read() 481 poll_fn(|cx| Pin::new(request.body_mut()).poll_read(cx, &mut read_buf)) in ut_client_request_builder_body()
H A D	http_body.rs	239 match Pin::new(&mut io).poll_read(cx, &mut read_buf) { in poll_read_io() 363 match Pin::new(&mut io).poll_read(cx, &mut read_buf) { in poll_read_io() 469 match Pin::new(&mut io).poll_read(cx, &mut read_buf) { in data()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/
H A D	mod.rs	131 fn poll_read( in poll_read() functions 160 Pin::new(&mut this.reader).poll_read(cx, buf) in poll_read() 233 ylong_runtime::futures::poll_fn(|cx| Pin::new(&mut uploader).poll_read(cx, &mut buf)) 248 ylong_runtime::futures::poll_fn(|cx| Pin::new(&mut multi_uploader).poll_read(cx, &mut buf)) 325 ylong_runtime::futures::poll_fn(|cx| Pin::new(&mut uploader).poll_read(cx, &mut buf))
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/
H A D	stream.rs	50 // poll_read separately. 51 fn poll_read( in poll_read() functions 56 Pin::new(&mut self.stream).poll_read(cx, buf) in poll_read()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A D	data_ref.rs	37 pub(crate) fn poll_read( 50 match data.poll_read(cx, &mut read_buf) {
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/
H A D	split.rs	71 fn poll_read( in poll_read() functions 77 guard.stream().poll_read(cx, buf) in poll_read()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/
H A D	async_buf_reader.rs	181 fn poll_read( in poll_read() functions 189 return unsafe { Pin::new_unchecked(&mut this.inner).poll_read(cx, buf) }; in poll_read() 206 poll_ready!(Pin::new_unchecked(&mut this.inner).poll_read(cx, &mut read_buf))?;
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A D	stream.rs	338 fn poll_read( in poll_read() functions 343 self.source.poll_read(cx, buf) in poll_read()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A D	stream.rs	599 fn poll_read( in poll_read() functions 604 self.source.poll_read(cx, buf) in poll_read()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/
H A D	pty.rs	179 fn poll_read( in poll_read() functions 184 self.0.poll_read(cx, buf) in poll_read() 229 fn poll_read( in poll_read() functions 234 self.0 .0.poll_read(cx, buf) in poll_read() 288 fn poll_read( in poll_read() functions 293 self.0 .0.poll_read(cx, buf) in poll_read()
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/
H A D	simple.rs	205 fn poll_read( in poll_read() functions 226 match Pin::new(status).poll_read(cx, buf) { in poll_read() 465 let result = unsafe { Pin::new_unchecked(stream).poll_read(cx, buf) }; in poll_read_curr() 483 fn poll_read( in poll_read() functions 743 poll_fn(|cx| Pin::new(&mut mp).poll_read(cx, &mut read_buf)) 794 poll_fn(|cx| Pin::new(&mut mp).poll_read(cx, &mut read_buf))
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/
H A D	c_ssl_stream.rs	93 fn poll_read( in poll_read() functions
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/
H A D	http2.rs	351 fn poll_read( in poll_read() functions 505 poll_fn(|cx| Pin::new(&mut text_io).poll_read(cx, &mut buffer)) in ut_http2_body_poll_read()
H A D	http3.rs	296 fn poll_read( in poll_read() functions
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A D	output.rs	85 match Pin::new(&mut self.reader).poll_read(cx, &mut read_buf) {
H A D	streams.rs	42 // Wait for poll_read or wait for window. 476 match stream.data.poll_read(cx, buf) { in poll_sized_data()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
H A D	async_source.rs	175 pub(crate) fn poll_read<'a>(
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/
H A D	mix.rs	208 match Pin::new(data).poll_read(cx, &mut buf) { in poll_data()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/
H A D	streams.rs	487 match stream.data.poll_read(cx, buf) { 704 // Wait for poll_read or wait for window.
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/
H A D	async_file.rs	526 fn poll_read( in poll_read() functions
/commonlibrary/rust/ylong_http/ylong_http/src/body/
H A D	chunk.rs	202 match Pin::new(&mut *self.from).poll_read(_cx, &mut read_buf) { in poll_partial()

Completed in 16 milliseconds

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