fix(core): use futures_channel directly

temporalio · Oct 10, 2024 · f701db1 · f701db1
1 parent c6d001f
commit f701db1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/core/Cargo.toml b/core/Cargo.toml
@@ -33,7 +33,7 @@ enum_dispatch = "0.3"
 enum-iterator = "2"
 flate2 = { version = "1.0", optional = true }
 futures-util = { version = "0.3", default-features = false }
-futures-channel = { version = "0.3", default-features = false }
+futures-channel = { version = "0.3", default-features = false, features = ["std"]}
 governor = "0.6"
 http-body-util = { version = "0.1", optional = true }
 hyper = { version = "1.2", optional = true }

diff --git a/tests/integ_tests/workflow_tests.rs b/tests/integ_tests/workflow_tests.rs
@@ -18,7 +18,8 @@ mod upsert_search_attrs;
 
 use crate::integ_tests::{activity_functions::echo, metrics_tests};
 use assert_matches::assert_matches;
-use futures_util::{channel::mpsc::UnboundedReceiver, future, SinkExt, StreamExt};
+use futures_channel::mpsc::UnboundedReceiver;
+use futures_util::{future, SinkExt, StreamExt};
 use std::{
     collections::{HashMap, HashSet},
     sync::{
@@ -92,7 +93,7 @@ async fn parallel_workflows_same_queue() {
     let handles: Vec<_> = run_ids
         .iter()
         .map(|run_id| {
-            let (tx, rx) = futures_util::channel::mpsc::unbounded();
+            let (tx, rx) = futures_channel::mpsc::unbounded();
             send_chans.insert(run_id.clone(), tx);
             tokio::spawn(wf_task(core.clone(), rx))
         })