Fix multi-threading module

private-attribution · Feb 16, 2024 · 6cbee84 · 6cbee84
1 parent fb9b908
commit 6cbee84
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/ipa-core/src/seq_join/multi_thread.rs b/ipa-core/src/seq_join/multi_thread.rs
@@ -5,7 +5,8 @@ use std::{
     task::{Context, Poll},
 };
 
-use futures::stream::Fuse;
+use futures::{stream::Fuse, StreamExt};
+use pin_project::pin_project;
 use tracing::{Instrument, Span};
 
 use super::*;