From 1b73c2c67a5ede5dd7fc887defaa962a13e31e57 Mon Sep 17 00:00:00 2001
From: Alexander Lyon <arlyon@me.com>
Date: Fri, 9 Feb 2024 18:26:02 +0000
Subject: [PATCH] fix compile on macOS

---
 crates/turborepo-filewatch/src/lib.rs | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/crates/turborepo-filewatch/src/lib.rs b/crates/turborepo-filewatch/src/lib.rs
index 594aa23cb5418..eeb81365d4435 100644
--- a/crates/turborepo-filewatch/src/lib.rs
+++ b/crates/turborepo-filewatch/src/lib.rs
@@ -211,8 +211,14 @@ async fn watch_events(
     _watch_root: AbsoluteSystemPathBuf,
     mut recv_file_events: mpsc::Receiver<EventResult>,
     exit_signal: tokio::sync::oneshot::Receiver<()>,
-    broadcast_sender: broadcast::Sender<Result<Event, NotifyError>>,
+    mut broadcast_sender: OptionalWatch<broadcast::Sender<Result<Event, NotifyError>>>,
 ) {
+    let Ok(broadcast_sender) = broadcast_sender.get().await.map(|b| b.clone()) else {
+        // if we are never sent a sender, we should not run the watcher
+        tracing::debug!("no downstream listeners, exiting");
+        return;
+    };
+
     let mut exit_signal = exit_signal;
     'outer: loop {
         tokio::select! {