1
1
//! Internet Message Format reception pipeline.
2
2
3
3
use std:: collections:: HashSet ;
4
+ use std:: iter;
4
5
use std:: str:: FromStr ;
5
6
6
7
use anyhow:: { Context as _, Result } ;
@@ -2064,7 +2065,7 @@ async fn create_group(
2064
2065
context
2065
2066
. sql
2066
2067
. transaction ( |transaction| {
2067
- for ( contact_id, ts) in std :: iter:: zip (
2068
+ for ( contact_id, ts) in iter:: zip (
2068
2069
to_ids. iter ( ) ,
2069
2070
chat_group_member_timestamps. iter ( ) . take ( to_ids. len ( ) ) ,
2070
2071
) {
@@ -2077,7 +2078,7 @@ async fn create_group(
2077
2078
) ?;
2078
2079
}
2079
2080
2080
- for ( contact_id, ts) in std :: iter:: zip (
2081
+ for ( contact_id, ts) in iter:: zip (
2081
2082
past_ids. iter ( ) ,
2082
2083
chat_group_member_timestamps. iter ( ) . skip ( to_ids. len ( ) ) ,
2083
2084
) {
@@ -2269,7 +2270,7 @@ async fn apply_group_changes(
2269
2270
context
2270
2271
. sql
2271
2272
. transaction ( |transaction| {
2272
- for ( contact_id, ts) in std :: iter:: zip (
2273
+ for ( contact_id, ts) in iter:: zip (
2273
2274
to_ids. iter ( ) ,
2274
2275
chat_group_member_timestamps. iter ( ) . take ( to_ids. len ( ) ) ,
2275
2276
) {
@@ -2293,7 +2294,7 @@ async fn apply_group_changes(
2293
2294
}
2294
2295
}
2295
2296
2296
- for ( contact_id, ts) in std :: iter:: zip (
2297
+ for ( contact_id, ts) in iter:: zip (
2297
2298
past_ids. iter ( ) ,
2298
2299
chat_group_member_timestamps. iter ( ) . skip ( to_ids. len ( ) ) ,
2299
2300
) {
0 commit comments