连接 rxjs Observables

Question

是否可以连接多个 observables？

例如：我有 3 个功能：

ensureUserLogged():Observable<boolean>

createEntity():Observable<Entity>

checkEntity():Observable<boolean>

我想做这样的事情：

Observable.combine (ensureUserLogged(), createEntity(), checkEntity()).subscribe (
    checkEntityResult => console.log (checkEntityResult),
    error => console.log (error)
);

或类似的东西：

ensureUserLogged().then (logged => createEntity()).then (newEntity => checkEntity ())...

否则我需要写一个丑陋的金字塔：

ensureUserLogged().subscribe (
    res => {
        createEntity ().subscribe (
            res => {
                checkEntity ().subscribe (
                    res => { console.log ("I'm finally here") },
                    error {}
                )
            },
            err => {
            }
        );
    },
    err => {
    }
)

有什么可以实现我的意愿吗？

谢谢

Answer 1

您需要使用 Observable.forkJoin 进行 并行执行:

Observable.forkJoin(ensureUserLogged(), createEntity(), checkEntity()).subscribe (
  checkEntityResult => console.log (checkEntityResult),
  error => console.log (error)
);

checkEntityResult 将对应一个包含每个元素的数组：第一个为 ensureUserLogged、...

的结果

要执行系列，您需要使用flatMap运算符：

ensureUserLogged().flatMap((resultOfEnsureUserLogged) => {
  return createEntity();
}).flatMap((resultOfCreateEntity) => {
  return checkEntity();
}).subscribe((resultOfChekEntity) => {
  (...)
});

你会注意到你可以混合东西。例如：

ensureUserLogged().flatMap((resultOfEnsureUserLogged) => {
  return Observable.forJoin(createEntity(), checkEntity());
}).subscribe((resultOfCreateEntityAndChekEntity) => {
  (...)
});

连接 rxjs Observables

Concatenate rxjs Observables

typescript

angular

rxjs

observable

rxjs5