Skip to content

Commit 8a4810d

Browse files
Fix clippy warnings in hydro_test SQS module
- hydro_test/src/aws/sqs.rs: Replace redundant closures `|vec| futures_util::stream::iter(vec)` with direct function reference `futures_util::stream::iter` (lines 45 and 70) - hydro_test/examples/aws_sqs.rs: Replace explicit auto-deref `&*args.queue_url` with `&args.queue_url` (lines 63 and 80) Co-authored-by: Infinity 🤖 <infinity@hydro.run>
1 parent 2b8f16a commit 8a4810d

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

hydro_test/examples/aws_sqs.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
6060
{
6161
let sdk_config = source_sdk_config(&process_recv);
6262
let sqs_client = sqs_client(sdk_config);
63-
source_sqs_standard(sqs_client, &*args.queue_url)
63+
source_sqs_standard(sqs_client, &args.queue_url)
6464
.assume_ordering::<TotalOrder>(
6565
nondet!(/** Print all messages at least once in arbitrary order */),
6666
)
@@ -77,7 +77,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
7777
let input_messages = process_send
7878
.source_iter(q!(["hello", "world"].repeat(10).into_iter()))
7979
.map(q!(str::to_owned));
80-
dest_sqs(sqs_client, input_messages, &*args.queue_url);
80+
dest_sqs(sqs_client, input_messages, &args.queue_url);
8181
}
8282

8383
// Extract the IR BEFORE the builder is consumed by deployment methods

hydro_test/src/aws/sqs.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ pub fn source_sqs_standard<'a, Loc: Location<'a>>(
4242
Some((vec, ()))
4343
}
4444
})
45-
.flat_map(|vec| futures_util::stream::iter(vec))
45+
.flat_map(futures_util::stream::iter)
4646
}))
4747
.weaken_retries()
4848
.weaken_ordering()
@@ -67,7 +67,7 @@ pub fn source_sqs_fifo<'a, Loc: Location<'a>>(
6767
Some((vec, ()))
6868
}
6969
})
70-
.flat_map(|vec| futures_util::stream::iter(vec))
70+
.flat_map(futures_util::stream::iter)
7171
}))
7272
}
7373

0 commit comments

Comments
 (0)