and fix rust test

versatica · Dec 12, 2023 · 2b3e88f · 2b3e88f
1 parent 712c930
commit 2b3e88f
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/rust/tests/integration/data_consumer.rs b/rust/tests/integration/data_consumer.rs
@@ -327,12 +327,10 @@ fn set_subchannels() {
         let (_worker, _router, transport1, data_producer) = init().await;
 
         let data_consumer = transport1
-            .consume_data({
-                DataConsumerOptions::new_sctp_unordered_with_life_time(
-                    data_producer.id(),
-                    4000,
-                );
-            })
+            .consume_data(DataConsumerOptions::new_sctp_unordered_with_life_time(
+                data_producer.id(),
+                4000,
+            ))
             .await
             .expect("Failed to consume data");