pub async fn run( url: String, token: String, store: Arc<TaskStore>, notify: Arc<Notify>, )
Keeps one stream open for the life of the daemon, reconnecting with backoff