Home
last modified time | relevance | path

Searched refs:text_io (Results 1 - 2 of 2) sorted by relevance

/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/
H A Dhttp3.rs196 text_io: &mut TextIo<S>, in match_channel_message()
202 text_io.remain = Some(frame); in match_channel_message()
203 text_io.offset = 0; in match_channel_message()
213 text_io.offset += fill_len; in match_channel_message()
214 text_io.remain = Some(frame); in match_channel_message()
218 Self::end_read(text_io, data_len) in match_channel_message()
229 text_io.is_closed = true; in match_channel_message()
241 fn end_read(text_io: &mut TextIo<S>, data_len: usize) -> Option<Poll<std::io::Result<()>>> { in end_read()
242 text_io.offset = 0; in end_read()
243 text_io in end_read()
[all...]
H A Dhttp2.rs117 let text_io = TextIo::new(conn); in frame_2_response()
126 let body = HttpBody::new(message.interceptor, length, Box::new(text_io), &[0u8; 0])?; in frame_2_response()
244 text_io: &mut TextIo<S>, in match_channel_message()
250 text_io.remain = Some(frame); in match_channel_message()
251 text_io.offset = 0; in match_channel_message()
261 text_io.offset += fill_len; in match_channel_message()
262 text_io.remain = Some(frame); in match_channel_message()
266 Self::end_read(text_io, frame.flags().is_end_stream(), data_len) in match_channel_message()
271 text_io.is_closed = true; in match_channel_message()
290 text_io in end_read()
467 let mut text_io = TextIo::new(conn); ut_http2_body_poll_read() variables
[all...]

Completed in 1 milliseconds