We can't do this because this is async. This could use atomic or a mutex ... but really is it worth it? Maybe instead we can inherit a context which is cancelled on shutdown?