如何使用 rxjs 和 redux observable 实现 promise 类型的场景?

How to implement promise type scenario using rxjs and redux observable?

我有一个场景,在保存表单数据后,用户将在 React 组件中看到一条通知。我不想将数据保存在 redux 存储中。如何使用 redux observable 和 react 做到这一点?

如果您询问如何将承诺变成可观察的,可以使用 from 运算符。在您的场景中,您可以尝试下面的代码。

const saveObservable$ = from(httpSvc.save(reqBody);
saveObservable$.pipe(
switchMap(saveMessage => from(notificationService.showNotificataion(saveMessage))),
take(1) // this will only take the first stream so we don't get memory leaks after subscribing.
).subscribe();