2 files changed, 22 insertions, 6 deletions
diff --git a/cli/tools/repl/mod.rs b/cli/tools/repl/mod.rs
index bfba62752..0a6d9b9e9 100644
--- a/cli/tools/repl/mod.rs
+++ b/cli/tools/repl/mod.rs
@@ -7,6 +7,7 @@ use crate::colors;
 use crate::file_fetcher::FileFetcher;
 use crate::proc_state::ProcState;
 use deno_core::error::AnyError;
+use deno_core::futures::StreamExt;
 use deno_runtime::permissions::Permissions;
 use deno_runtime::permissions::PermissionsContainer;
 use rustyline::error::ReadlineError;
@@ -30,8 +31,11 @@ async fn read_line_and_poll(
   message_handler: &mut RustylineSyncMessageHandler,
   editor: ReplEditor,
 ) -> Result<String, ReadlineError> {
+  #![allow(clippy::await_holding_refcell_ref)]
   let mut line_fut = tokio::task::spawn_blocking(move || editor.readline());
   let mut poll_worker = true;
+  let notifications_rc = repl_session.notifications.clone();
+  let mut notifications = notifications_rc.borrow_mut();
 
   loop {
     tokio::select! {
@@ -57,7 +61,20 @@ async fn read_line_and_poll(
         }
 
         poll_worker = true;
-      },
+      }
+      message = notifications.next() => {
+        if let Some(message) = message {
+          let method = message.get("method").unwrap().as_str().unwrap();
+          if method == "Runtime.exceptionThrown" {
+            let params = message.get("params").unwrap().as_object().unwrap();
+            let exception_details = params.get("exceptionDetails").unwrap().as_object().unwrap();
+            let text = exception_details.get("text").unwrap().as_str().unwrap();
+            let exception = exception_details.get("exception").unwrap().as_object().unwrap();
+            let description = exception.get("description").unwrap().as_str().unwrap();
+            println!("{text} {description}");
+          }
+        }
+      }
       _ = repl_session.run_event_loop(), if poll_worker => {
         poll_worker = false;
       }
diff --git a/cli/tools/repl/session.rs b/cli/tools/repl/session.rs
index b2645097c..6f8db6fcd 100644
--- a/cli/tools/repl/session.rs
+++ b/cli/tools/repl/session.rs
@@ -1,5 +1,7 @@
 // Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
 
+use std::cell::RefCell;
+use std::rc::Rc;
 use std::sync::Arc;
 
 use crate::args::CliOptions;
@@ -128,12 +130,9 @@ pub struct ReplSession {
   session: LocalInspectorSession,
   pub context_id: u64,
   pub language_server: ReplLanguageServer,
+  pub notifications: Rc<RefCell<UnboundedReceiver<Value>>>,
   has_initialized_node_runtime: bool,
   referrer: ModuleSpecifier,
-  // FIXME(bartlomieju): this field should be used to listen
-  // for "exceptionThrown" notifications
-  #[allow(dead_code)]
-  notification_rx: UnboundedReceiver<Value>,
 }
 
 impl ReplSession {
@@ -193,7 +192,7 @@ impl ReplSession {
       language_server,
       has_initialized_node_runtime: false,
       referrer,
-      notification_rx,
+      notifications: Rc::new(RefCell::new(notification_rx)),
     };
 
     // inject prelude