Searched defs:reader (Results 1 – 13 of 13) sorted by relevance
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| D | decoder.rs | 235 let reader = ReadableBytes::from(&stream.buffer.as_slice()[stream.offset..]); in decode() localVariable
242 let reader = ReadableBytes::from(&stream.buffer.as_slice()[stream.offset..]); in decode() localVariable
381 let mut reader = ReadableBytes::from(&self.buffer.as_slice()[self.offset..]); in decode_stream_type() localVariable
399 let mut reader = ReadableBytes::from(&self.buffer.as_slice()[self.offset..]); in decode_push_id() localVariable
417 let mut reader = ReadableBytes::from(&self.buffer.as_slice()[self.offset..]); in decode_frame_type() localVariable
462 let mut reader = ReadableBytes::from(&self.buffer.as_slice()[self.offset..]); in decode_payload_len() localVariable
507 let mut reader = ReadableBytes::from(&self.buffer.as_slice()[self.offset..]); in decode_data_payload() localVariable
587 let mut reader = ReadableBytes::from(&self.buffer.as_slice()[self.offset..]); in decode_headers_payload() localVariable
621 let mut reader = ReadableBytes::from(&self.buffer.as_slice()[self.offset..]); in decode_variable_payload() localVariable
665 let mut reader = ReadableBytes::from(&self.buffer.as_slice()[self.offset..]); in decode_settings_payload() localVariable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| D | read_task.rs | 41 reader: Option<&'a mut R>, field
62 let mut reader = take_reader!(self); in poll() localVariable
80 reader: &'a mut R, field
150 reader: &'a mut R, field
226 reader: Option<&'a mut R>, field
247 let mut reader = take_reader!(self); in poll() localVariable
274 reader: &'a mut R, field
342 reader: &'a mut R, field
382 reader: R, field
426 reader: R, field
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| D | builder.rs | 62 pub fn reader<R: AsyncRead>(self, reader: R) -> UploaderBuilder<WantsOperator<R>> { in reader() method
100 reader: R, field
171 reader: R, field
|
| D | mod.rs | 89 reader: R, field
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | mod.rs | 33 mod reader; module
|
| D | reader.rs | 237 let reader = BodyReader::new(DefaultBodyProcessor).read_timeout(Timeout::none()); in ut_body_reader_read_timeout() localVariable
|
| D | client.rs | 523 let reader = "Hello World"; in ut_request_client_err() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| D | text.rs | 472 let reader = "Hello World!".as_bytes(); in ut_text_body_from_reader() localVariable
483 let reader = "Hello World!".as_bytes(); in ut_text_body_from_async_reader() localVariable
559 let reader = "Hello World!".as_bytes(); in ut_text_body_from_reader_syn_data() localVariable
596 let reader = "Hello World!".as_bytes(); in text_body_from_async_reader_asyn_data() localVariable
|
| D | mod.rs | 473 pub(crate) reader: T, field
498 pub(crate) reader: T, field
|
| /commonlibrary/rust/ylong_json/src/ |
| D | lib.rs | 57 mod reader; module
|
| D | deserializer.rs | 48 pub(crate) reader: R, field
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | output.rs | 43 reader: ReadHalf<S>, field
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| D | schedule_io.rs | 55 reader: Option<Waker>, field
|