pub async fn subscribe(
        &self,
    ) -> Result<broadcast::Receiver<Result<Event, NotifyError>>, RecvError> {
        let mut receiver = self.receiver.clone();
        receiver.get().await.map(|r| r.resubscribe())
    }
A convenience method around the sender watcher that waits for file
watching to be ready and then returns a handle to the file stream.
crates/turborepo-filewatch/src/lib.rs