pub async fn done(&self) {
        // Receiver is dropped once the worker task completes
        self.close.closed().await;
    }
Wait until handler is finished and all subscribers finish their cleanup
work
crates/turborepo-signals/src/lib.rs