Removed unneeded clone()s (#63)

grumlimited · May 13, 2024 · 8c7066d · 8c7066d
1 parent e90df9f
commit 8c7066d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 12 deletions.
diff --git a/src/aws.rs b/src/aws.rs
@@ -155,7 +155,7 @@ pub mod client {
             let inner = aws_config::defaults(BehaviorVersion::latest()).region(region_provider);
 
             let inner = match endpoint_url {
-                Some(endpoint_url) => inner.endpoint_url(endpoint_url.as_str()),
+                Some(endpoint_url) => inner.endpoint_url(endpoint_url),
                 None => inner,
             };
 

diff --git a/src/main.rs b/src/main.rs
@@ -120,20 +120,13 @@ async fn main() -> Result<()> {
         selected_shards
             .iter()
             .map(|shard_id| {
-                let tx_ticker_updates = tx_ticker_updates.clone();
-                let tx_records = tx_records.clone();
-                let client = client.clone();
-                let stream_name = opt.stream_name.clone();
-                let shard_id = shard_id.clone();
-                let semaphore = semaphore.clone();
-
                 let shard_processor = kinesis::helpers::new(
-                    client,
-                    stream_name,
-                    shard_id,
+                    client.clone(),
+                    opt.stream_name.clone(),
+                    shard_id.clone(),
                     from_datetime,
                     to_datetime,
-                    semaphore,
+                    semaphore.clone(),
                     tx_records.clone(),
                     tx_ticker_updates.clone(),
                 );