| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/ |
| H A D | mod.rs | 48 type Data: ParSplit; types
51 fn into_par_iter(self) -> ParIter<Self::Data>; in into_par_iter()
60 type Data = T; types
61 fn into_par_iter(self) -> ParIter<Self::Data> { in into_par_iter()
69 type Data: ParSplit + 'a; types
72 fn par_iter(&'a self) -> ParIter<Self::Data>; in par_iter()
79 type Data = <&'a T as IntoParIter>::Data; in par_iter() types
80 fn par_iter(&'a self) -> ParIter<Self::Data> { in par_iter()
88 type Data types
98 type Data = <&'a mut T as IntoParIter>::Data; par_iter_mut() types
[all...] |
| H A D | array.rs | 17 type Data = &'a [T]; types
24 type Data = &'a mut [T]; types
|
| H A D | vec.rs | 38 type Data = &'a [T]; types
45 type Data = &'a mut [T]; in into_par_iter() types
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/collections/ |
| H A D | mod.rs | 25 type Data = $iter; types
27 fn into_par_iter(self) -> ParIter<Self::Data> { in into_par_iter()
28 <Self::Data>::into_par_iter(self.$f().collect()) in into_par_iter()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | frame.rs | 16 /// Data Frame type code.
57 Data(Data),
80 /// Http3 Data frame payload, containing the body data.
82 pub struct Data { structure names
214 impl Data { impls
215 /// Creates a new Data instance containing the provided data.
217 Data { data } in new()
|
| H A D | mod.rs | 30 Data, Frame, Headers, Payload, Settings, DATA_FRAME_TYPE, HEADERS_FRAME_TYPE,
|
| H A D | decoder.rs | 21 CancelPush, Data, GoAway, Headers, MaxPushId, Payload, PushPromise, Settings, DATA_FRAME_TYPE,
514 Payload::Data(Data::new(Vec::from(reader.remaining()))), in decode_data_payload()
524 Payload::Data(Data::new(Vec::from(reader.slice(payload_len)?))), in decode_data_payload()
|
| H A D | encoder.rs | 42 // Data Frame
76 /// use ylong_http::h3::{Data, Frame, FrameEncoder, Payload};
81 /// Payload::Data(Data::new(vec![b'h', b'e', b'l', b'l', b'o'])),
167 /// use ylong_http::h3::{Data, Frame, FrameEncoder, Payload};
172 /// Payload::Data(Data::new(vec![b'h', b'e', b'l', b'l', b'o'])),
494 if let Payload::Data(d) = frame.payload() { in encode_data_len()
617 if let Payload::Data(d) = frame.payload() { in encode_data_payload()
652 use crate::h3::{Data, Fram
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | frame.rs | 65 Data = 0x0,
85 Data(Data),
134 pub struct Data { structure names
313 Payload::Data(_) => FrameType::Data, in frame_type()
342 impl Data { impls
343 /// Creates a new Data instance containing the provided data.
345 Data { data } in new()
353 /// Returns the number of bytes in the `Data` payloa
[all...] |
| H A D | mod.rs | 65 Data, Frame, FrameFlags, Goaway, Headers, Payload, Ping, RstStream, Setting, Settings,
|
| H A D | encoder.rs | 161 Payload::Data(data) => { in set_frame()
536 if let Payload::Data(_) = frame.payload() { in encode_data_header()
611 if let Payload::Data(data_frame) = frame.payload() { in encode_data_payload()
639 let padding_len = if let Payload::Data(data_frame) = frame.payload() { in encode_padding()
1325 Data, FrameFlags, Goaway, Headers, Ping, Priority, RstStream, Settings, WindowUpdate,
1333 /// 2. Creates a `Frame` with `Payload::Data`.
1345 Payload::Data(Data::new(data_payload.clone())), in ut_data_frame_encoding()
1526 /// Data, Headers.
1530 /// 2. Creates multiple frames including Headers and Data frame
[all...] |
| H A D | decoder.rs | 23 Data, FrameFlags, Goaway, Ping, Priority, RstStream, WindowUpdate, ACK_MASK, END_HEADERS_MASK,
609 frame::Payload::Data(Data::new(vec![])), in decode_data_payload()
631 frame::Payload::Data(Data::new(data)), in decode_data_payload()
985 Payload::Data(data) => {
1142 /// Test Data Frames in Segments.
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http2.rs | 254 Payload::Data(data) => { in match_channel_message()
314 Payload::Data(data) => { in read_remaining_data()
455 use ylong_http::h2::{Data, Frame, FrameFlags}; in ut_http2_body_poll_read()
471 Payload::Data(Data::new(vec![b'a'; 128])), in ut_http2_body_poll_read()
476 Payload::Data(Data::new(vec![b'a'; 2])), in ut_http2_body_poll_read()
481 Payload::Data(Data::new(vec![b'a'; 10])), in ut_http2_body_poll_read()
|
| H A D | http3.rs | 206 Payload::Data(data) => { in match_channel_message()
259 Payload::Data(data) => { in read_remaining_data()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| H A D | streams.rs | 20 use ylong_http::h3::{Data, Frame, H3Error, H3ErrorCode, Payload, DATA_FRAME_TYPE};
493 Payload::Data(Data::new(data_vec)),
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | streams.rs | 20 use ylong_http::h2::{Data, ErrorCode, Frame, FrameFlags, H2Error, Payload, StreamId};
487 Payload::Data(Data::new(data_vec)), in poll_sized_data()
496 Payload::Data(Data::new(data_vec)), in poll_sized_data()
|
| H A D | manager.rs | 266 Payload::Data(_) => { in poll_send_frame()
311 Payload::Data(_data) => { in poll_recv_frame()
471 let data = if let Payload::Data(data) = frame.payload() { in recv_data_frame()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| H A D | chunk.rs | 90 // Data encoding status
92 // Data encode is processing
94 // Data encode is completed
96 // Data encode is finished and return result
453 ChunkState::Data => { in encode()
491 self.chunk_status = ChunkState::Data; in meta_crlf_encode()
670 Data,
711 Data,
967 Stage::Data => self.decode_data(remains), in decode()
1000 && (chunk.state == ChunkState::Data || chun in match_decode_result()
[all...] |