Searched refs:chunk (Results 1 - 6 of 6) sorted by relevance
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | base64.rs | 19 for chunk in input.chunks(3) {
20 output.push(BASE64_TABLE[((chunk[0] >> 2) & 0x3f) as usize]);
21 if chunk.len() == 3 {
22 output.push(BASE64_TABLE[(((chunk[0] & 0x3) << 4) | ((chunk[1] >> 4) & 0xf)) as usize]);
23 output.push(BASE64_TABLE[(((chunk[1] & 0xf) << 2) | ((chunk[2] >> 6) & 0x3)) as usize]);
24 output.push(BASE64_TABLE[(chunk[2] & 0x3f) as usize]);
25 } else if chunk.len() == 2 {
26 output.push(BASE64_TABLE[(((chunk[
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | http_body.rs | 65 pub(crate) fn chunk(pre: &[u8], io: BoxStreamData, is_trailer: bool) -> Self {
106 Kind::Chunk(ref mut chunk) => chunk.data(buf), in data()
112 Kind::Chunk(ref mut chunk) => chunk.decoder.get_trailer().map_err(|_| { in trailer()
225 // Return if we find a 0-sized chunk. in data()
248 // Return if we find a 0-sized chunk. in data()
286 for chunk in chunks.into_iter() { in merge_chunks()
287 if chunk.trailer().is_some() { in merge_chunks()
288 if chunk in merge_chunks()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| H A D | chunk.rs | 32 /// A chunk body is used to encode body to send message by chunk in `HTTP/1.1`
35 /// This chunk body encoder supports you to use the chunk encode method multiple
206 // chunk idx reset zero in poll_partial()
646 // Stage of decode chunks, The elements of the chunk-body are as follows:
648 // | chunked-body = *chunk |
649 // | last-chunk |
653 // | chunk = chunk
[all...] |
| H A D | mod.rs | 25 //! a sequence of data chunks, one zero-length chunk, and a trailer section —
27 //! the transfer coding has been decoded; it does not include the chunk lengths,
44 mod chunk; modules
50 pub use chunk::{Chunk, ChunkBody, ChunkBodyDecoder, ChunkExt, ChunkState, Chunks};
339 /// let mut chunk = ChunkBody::from_bytes(chunk_body_bytes.as_bytes());
340 /// // read chunk body and return headers
341 /// let res = chunk.trailer().await.unwrap().unwrap();
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | http_body.rs | 125 Kind::Chunk(ref mut chunk) => chunk.data(cx, buf), in poll_data()
144 Kind::Chunk(ref mut chunk) => { in poll_trailer()
145 match chunk.data(cx, &mut read_buf) { in poll_trailer()
154 Poll::Ready(Ok(chunk.decoder.get_trailer().map_err(|e| { in poll_trailer()
168 Kind::Chunk(ref mut chunk) => chunk.io.as_mut(), in drop()
457 // Return if we find a 0-sized chunk. in data()
480 // Return if we find a 0-sized chunk. in data()
528 for chunk i in merge_chunks()
597 let mut chunk = HttpBody::new( global() variables
621 let mut chunk = HttpBody::new( global() variables
655 let mut chunk = HttpBody::new( global() variables
699 let mut chunk = HttpBody::new( global() variables
721 let mut chunk = HttpBody::new( global() variables
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | mod.rs | 301 let chunk = HttpBody::new(
310 let response = Response::from_raw_parts(result.0, chunk);
|
Completed in 6 milliseconds