| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | spawn.rs | 39 for (times, handle) in handles.into_iter().enumerate() { in sdv_one_core_test()
56 for (times, handle) in handles.into_iter().enumerate() { in sdv_two_core_test()
73 for (times, handle) in handles.into_iter().enumerate() { in sdv_three_core_test()
90 for (times, handle) in handles.into_iter().enumerate() { in sdv_four_core_test()
107 for (times, handle) in handles.into_iter().enumerate() { in sdv_eight_core_test()
124 for (times, handle) in handles.into_iter().enumerate() { in sdv_max_core_test()
141 for (times, handle) in handles.into_iter().enumerate() { in sdv_multi_future_in_async()
159 for (times, handle) in handles.into_iter().enumerate() { in sdv_multi_async_in_async()
|
| H A D | spawn_blocking.rs | 35 for (times, handle) in handles.into_iter().enumerate() { in ffrt_spawn_blocking_test()
49 for (times, handle) in handles.into_iter().enumerate() { in ffrt_spawn_blocking_test()
75 for (times, handle) in handles.into_iter().enumerate() { in test_spawn()
88 for (times, handle) in handles.into_iter().enumerate() { in test_spawn()
102 for (times, handle) in handles.into_iter().enumerate() { in test_spawn()
|
| H A D | singleton_runtime.rs | 52 for (times, handle) in handles.into_iter().enumerate() { in sdv_concurrently_runtime_spawn_async_in_async_task()
80 for (times, handle) in handles.into_iter().enumerate() { in sdv_concurrently_spawn_async_in_async_task()
109 for (times, handle) in handles.into_iter().enumerate() { in sdv_concurrently_task_builder_spawn_async_in_async_task()
|
| H A D | async_pool.rs | 149 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_001()
209 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_002()
269 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_003()
329 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_004()
389 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_005()
449 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_006()
509 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_007()
569 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_008()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | stream.rs | 39 into_iter: std::vec::IntoIter<FrameKind>,
106 self.into_iter.next() in next()
114 fn into_iter(self) -> Self::IntoIter { in into_iter() functions
116 into_iter: self.list.into_iter(), in into_iter()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime_macros/src/ |
| H A D | select.rs | 83 builder.except_index = group.stream().into_iter().count(); in parse_group()
119 let buf = input.into_iter().collect::<Vec<_>>();
132 match inner.into_iter().next() { in group_num()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/ |
| H A D | headers.rs | 39 pub(crate) into_iter: IntoIter<HeaderName, HeaderValue>,
49 into_iter: headers.into_iter(),
59 HeaderStatus::Start => match self.into_iter.next() { in check_next()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
| H A D | resolver.rs | 128 for _socket in sockets.into_iter() { in ut_resolver_std_dns_resolver_resolve()
158 for _socket in sockets.into_iter() { in ut_resolver_std_dns_resolver_resolve()
|
| H A D | happy_eyeballs.rs | 134 let socket_addr = ResolvedAddrs::new(socket_addr.into_iter());
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
| H A D | multi.rs | 148 for (idx, xpart) in list.into_iter().enumerate() {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/ |
| H A D | mod.rs | 120 self.data.into_iter() in iter()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | decoder.rs | 61 /// let mut iter = frames.into_iter();
76 into_iter: std::vec::IntoIter<FrameKind>,
136 self.into_iter.next() in next()
144 fn into_iter(self) -> Self::IntoIter { in into_iter() functions
146 into_iter: self.list.into_iter(), in into_iter()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | http_body.rs | 286 for chunk in chunks.into_iter() { in merge_chunks()
311 for (ptr, len) in ptrs.into_iter() { in merge_chunks()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
| H A D | adapter.rs | 592 .into_iter() in stack_from_pem()
627 .into_iter() in from_pem()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/ |
| H A D | encoder.rs | 834 map: parts.map.into_iter(),
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | output.rs | 100 Ok(frames) => match self.poll_iterator_frames(cx, frames.into_iter()) {
|
| /commonlibrary/rust/ylong_http/ylong_http/src/ |
| H A D | headers.rs | 869 /// for (_name, _value) in headers.into_iter() { in iter()
873 fn into_iter(self) -> Self::IntoIter { in iter() functions
874 self.map.into_iter() in iter()
882 fn into_iter(self) -> Self::IntoIter { in into_iter() functions
891 fn into_iter(self) -> Self::IntoIter { in into_iter() functions
938 /// This struct is created by [`Headers::into_iter`].
940 /// [`Headers::into_iter`]: crate::headers::Headers::into_iter
950 /// for (_name, _value) in headers.into_iter() {
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| H A D | chunk.rs | 359 for (name, value) in trailer_headers.into_iter() { in set_trailer()
731 into_iter: std::vec::IntoIter<Chunk<'a>>,
755 fn new(into_iter: std::vec::IntoIter<Chunk>) -> ChunksIntoIter { in new()
756 ChunksIntoIter { into_iter } in new()
764 self.into_iter.next() in next()
772 &self.into_iter in deref()
795 fn into_iter(self) -> Self::IntoIter { in push() functions
796 ChunksIntoIter::new(self.chunks.into_iter()) in push()
1923 let mut iter = chunks.into_iter(); in ut_chunk_body_decode_2()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h1/request/ |
| H A D | encoder.rs | 509 let mut header_iter = header.into_iter(); in new()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/ |
| H A D | encoder.rs | 174 map: parts.map.into_iter(), in new()
|