АО
switchMap(
() =>
new Observable(observer => {
const abortController = new AbortController()
fetch(url, { signal: abortController.signal })
.then(res => {
observer.next(res)
observer.complete()
})
.catch(err => observer.error(err))
return () => abortController.abort()
})
)
Но это при условии что вы контролируете создание promise-ов