Task{ [xxx self] in for try await (self, foo) in combine(self, NotificationCenter.default.observe(...)) { ... } }