1 files changed, 13 insertions, 13 deletions
diff --git a/cli/tools/jupyter/mod.rs b/cli/tools/jupyter/mod.rs
index ea58328bb..cf1a44ea5 100644
--- a/cli/tools/jupyter/mod.rs
+++ b/cli/tools/jupyter/mod.rs
@@ -5,6 +5,9 @@ use crate::args::JupyterFlags;
 use crate::ops;
 use crate::tools::jupyter::server::StdioMsg;
 use crate::tools::repl;
+use crate::tools::test::create_single_test_event_channel;
+use crate::tools::test::reporters::PrettyTestReporter;
+use crate::tools::test::TestEventWorkerSender;
 use crate::util::logger;
 use crate::CliFactory;
 use deno_core::anyhow::Context;
@@ -19,13 +22,8 @@ use deno_runtime::permissions::Permissions;
 use deno_runtime::permissions::PermissionsContainer;
 use deno_terminal::colors;
 use tokio::sync::mpsc;
-use tokio::sync::mpsc::unbounded_channel;
 use tokio::sync::mpsc::UnboundedSender;
 
-use super::test::reporters::PrettyTestReporter;
-use super::test::TestEvent;
-use super::test::TestEventSender;
-
 mod install;
 pub(crate) mod jupyter_msg;
 pub(crate) mod server;
@@ -79,11 +77,13 @@ pub async fn kernel(
         connection_filepath
       )
     })?;
-  let (test_event_sender, test_event_receiver) =
-    unbounded_channel::<TestEvent>();
-  let test_event_sender = TestEventSender::new(test_event_sender);
-  let stdout = StdioPipe::File(test_event_sender.stdout());
-  let stderr = StdioPipe::File(test_event_sender.stderr());
+  let (worker, test_event_receiver) = create_single_test_event_channel();
+  let TestEventWorkerSender {
+    sender: test_event_sender,
+    stdout,
+    stderr,
+  } = worker;
+
   let mut worker = worker_factory
     .create_custom_worker(
       main_module.clone(),
@@ -94,9 +94,9 @@ pub async fn kernel(
       ],
       // FIXME(nayeemrmn): Test output capturing currently doesn't work.
       Stdio {
-        stdin: StdioPipe::Inherit,
-        stdout,
-        stderr,
+        stdin: StdioPipe::inherit(),
+        stdout: StdioPipe::file(stdout),
+        stderr: StdioPipe::file(stderr),
       },
     )
     .await?;