Skip to content

Commit a6ecac1

Browse files
committed
fix clippy by latest rust / solve hashbrown deps
1 parent 8b68e89 commit a6ecac1

6 files changed

Lines changed: 13 additions & 12 deletions

File tree

deny.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -178,6 +178,7 @@ deny = [
178178

179179
# Certain crates/versions that will be skipped when doing duplicate detection.
180180
skip = [
181+
{ name = "hashbrown" },
181182
]
182183
# Similarly to `skip` allows you to skip certain crates during duplicate
183184
# detection. Unlike skip, it also includes the entire tree of transitive

pubsub/src/apiv1/publisher_client.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ impl PublisherClient {
134134
.map_transient_err()
135135
};
136136
let response = invoke(retry.clone(), action).await?;
137-
all.extend(response.topics.into_iter());
137+
all.extend(response.topics);
138138
if response.next_page_token.is_empty() {
139139
return Ok(all);
140140
}
@@ -163,7 +163,7 @@ impl PublisherClient {
163163
.map_transient_err()
164164
};
165165
let response = invoke(retry.clone(), action).await?;
166-
all.extend(response.subscriptions.into_iter());
166+
all.extend(response.subscriptions);
167167
if response.next_page_token.is_empty() {
168168
return Ok(all);
169169
}
@@ -196,7 +196,7 @@ impl PublisherClient {
196196
.map_transient_err()
197197
};
198198
let response = invoke(retry.clone(), action).await?;
199-
all.extend(response.snapshots.into_iter());
199+
all.extend(response.snapshots);
200200
if response.next_page_token.is_empty() {
201201
return Ok(all);
202202
}

pubsub/src/apiv1/schema_client.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ impl SchemaClient {
7979
.map_transient_err()
8080
};
8181
let response = invoke(retry.clone(), action).await?;
82-
all.extend(response.schemas.into_iter());
82+
all.extend(response.schemas);
8383
if response.next_page_token.is_empty() {
8484
return Ok(all);
8585
}

pubsub/src/apiv1/subscriber_client.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,7 @@ impl SubscriberClient {
147147
.map_transient_err()
148148
};
149149
let response: ListSubscriptionsResponse = invoke(retry.clone(), action).await?;
150-
all.extend(response.subscriptions.into_iter());
150+
all.extend(response.subscriptions);
151151
if response.next_page_token.is_empty() {
152152
return Ok(all);
153153
}
@@ -331,7 +331,7 @@ impl SubscriberClient {
331331
.map_transient_err()
332332
};
333333
let response: ListSnapshotsResponse = invoke(retry.clone(), action).await?;
334-
all.extend(response.snapshots.into_iter());
334+
all.extend(response.snapshots);
335335
if response.next_page_token.is_empty() {
336336
return Ok(all);
337337
}

spanner/src/admin/database/database_admin_client.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ impl DatabaseAdminClient {
5454
.map_transient_err()
5555
};
5656
let response = invoke(retry.clone(), action).await?;
57-
all_databases.extend(response.databases.into_iter());
57+
all_databases.extend(response.databases);
5858
if response.next_page_token.is_empty() {
5959
return Ok(all_databases);
6060
}
@@ -340,7 +340,7 @@ impl DatabaseAdminClient {
340340
.map_transient_err()
341341
};
342342
let response = invoke(retry.clone(), action).await?;
343-
all_backups.extend(response.backups.into_iter());
343+
all_backups.extend(response.backups);
344344
if response.next_page_token.is_empty() {
345345
return Ok(all_backups);
346346
}
@@ -413,7 +413,7 @@ impl DatabaseAdminClient {
413413
.map_transient_err()
414414
};
415415
let response = invoke(retry.clone(), action).await?;
416-
all_operations.extend(response.operations.into_iter());
416+
all_operations.extend(response.operations);
417417
if response.next_page_token.is_empty() {
418418
return Ok(all_operations);
419419
}
@@ -450,7 +450,7 @@ impl DatabaseAdminClient {
450450
.map_transient_err()
451451
};
452452
let response = invoke(retry.clone(), action).await?;
453-
all_operations.extend(response.operations.into_iter());
453+
all_operations.extend(response.operations);
454454
if response.next_page_token.is_empty() {
455455
return Ok(all_operations);
456456
}

spanner/src/admin/instance/instance_admin_client.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ impl InstanceAdminClient {
5151
.map_transient_err()
5252
};
5353
let response = invoke(retry.clone(), action).await?;
54-
all.extend(response.instance_configs.into_iter());
54+
all.extend(response.instance_configs);
5555
if response.next_page_token.is_empty() {
5656
return Ok(all);
5757
}
@@ -102,7 +102,7 @@ impl InstanceAdminClient {
102102
.map_transient_err()
103103
};
104104
let response = invoke(retry.clone(), action).await?;
105-
all.extend(response.instances.into_iter());
105+
all.extend(response.instances);
106106
if response.next_page_token.is_empty() {
107107
return Ok(all);
108108
}

0 commit comments

Comments
 (0)