Карта каждого элемента потока обещанию и возвращает его значение

Question

Я пытаюсь отобразить каждый элемент потока на обещание, что-то вроде этого

myStream$ 
    .flatMap(id => Rx.Observable.fromPromise(database.get(id))) 
    .subscribe(val => console.log(val)); 

myStream$ имеет около 15 пунктов. Поскольку ни один из этих элементов не может быть найден в базе данных, каждое обещание будет отклонено. Я ожидал, что 15 журнальных выходов выведут ошибку. Однако все, что я получаю одна ошибка

rx.js: 77 Uncaught { "статус": 404, "имя": "not_found", "сообщение": "отсутствует", "причина": "отсутствует" }

Почему я получаю только одну ошибку вместо 15?

Answer 1

Такое поведение ожидается - всякий раз, когда возникает ошибка, поток будет завершен (другими словами: «stop & отписаться от подписки»).

Если вы хотите, чтобы ваш поток, чтобы завершить должным образом, независимо от одного или всех дб-запрос упущения, вы должны обработать ошибку внутри суб-поток, который оборачивает обещание, так как reject будет оцениваться как error в RxJS.

Rx.Observable.from([1,2,3,4,5]) 
 
    .flatMap(
 
    id => mockRequest(id) 
 
     .catch(error => { 
 
     console.error(error); 
 
     return Rx.Observable.empty(); // here we just return an empty stream, so the "main"-stream won't receive the error and continue with the other ids in the queue 
 
     }) 
 
) 
 
    .subscribe(
 
    val => console.log(val), 
 
    error => console.error("Stream hit an error and will finalize", error), 
 
    complete => console.log("Done!") 
 
); 
 
    
 
function mockRequest(id) { 
 
    return Rx.Observable.throw("Request failed for: " + id); 
 
}

<script src="https://unpkg.com/rxjs/bundles/Rx.min.js"></script>

Примечание: Вместо return Rx.Observable.empty(); вы, конечно, можете вернуть любое резервное-значение с помощью Observable.of("myFallbackValue")

---

Sidenote & предложения: Вы будете иметь проще, когда вы делаете ваш rest-calls непосредственно с RxJS и не должен завершать обещание. (Хотя технически и совершенно правомерные пути)