diff --git a/benchmark/src/main.rs b/benchmark/src/main.rs index 92a29ce0..bd9c7215 100644 --- a/benchmark/src/main.rs +++ b/benchmark/src/main.rs @@ -29,11 +29,11 @@ async fn main() -> Result<(), Box> { start_publisher( environment.clone(), &opts, - opts.streams.get(0).unwrap().clone(), + opts.streams.first().unwrap().clone(), ) .await?; - start_consumer(environment, &opts, opts.streams.get(0).unwrap().clone()).await?; + start_consumer(environment, &opts, opts.streams.first().unwrap().clone()).await?; loop { tokio::time::sleep(Duration::from_secs(60)).await; }