Я вызываю 2 службы в forkJoin
, вторая служба может выйти из строя, но я хочу, чтобы stream
продолжал работать, если вторая служба не работает.
Что у меня есть до сих пор:
Observable.forkJoin([
this.http.get('/service1'),
this.http.get('/service2').catch(error => Observable.empty())
])
.do(([result1, result2]: any[]) => {
//When service2 fails, I never get in here with .empty()
})
Observable.of(undefined)
или Observable.of(error)
работает. Но у меня сложилось впечатление, что возврат только empty Observable
из catch
приведет к тому, что вызов завершится автоматически, и поток продолжится?
Как обеспечить продолжение потока в случае сбоя службы2?
forkJoin
, если какой-либо источник пуст github.com/ReactiveX/rxjs/blob/master/spec/observables/ 20.04.2017