Remove extra seq_join

akoshelev · Dec 7, 2023 · 8eef9eb · 8eef9eb
1 parent d3d7426
commit 8eef9eb
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/ipa-core/src/protocol/ipa_prf/prf_sharding/mod.rs b/ipa-core/src/protocol/ipa_prf/prf_sharding/mod.rs
@@ -471,8 +471,7 @@ where
     }));
 
     // Execute all of the async futures (sequentially), and flatten the result
-    let flattenned_stream = seq_join(sh_ctx.active_work(), stream_of_per_user_circuits)
-        .flat_map(|x| stream_iter(x.unwrap()));
+    let flattenned_stream = stream_of_per_user_circuits.flat_map(|x| stream_iter(x.unwrap()));
 
     // modulus convert breakdown keys and trigger values
     let converted_bks_and_tvs = convert_bits(