如何使用 rxjs 和 redux observable 实现 Promise 类型的场景？

Posted 2023-02-19

【中文标题】如何使用 rxjs 和 redux observable 实现 Promise 类型的场景？

【英文标题】：How to implement promise type scenario using rxjs and redux observable?

【发布时间】：2021-06-11 03:07:50

【问题描述】：

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

【问题讨论】：

我认为解决方案主要取决于您用于通知的反应组件。示例：react-toastify 导出一个函数toast，它允许通过副作用直接在您的史诗中显示通知（在保存表单数据之后）。如果您需要更具体的答案，只需添加有关您的问题的更多信息（史诗的相关部分和通知反应组件）

【参考方案1】：

如果你想问如何将一个 Promise 变成一个 observable，你可以使用 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();

【讨论】：

您的解决方案可以使用 angular，但他询问的是 redux-observable ;-)

好的，但是这个解决方案实际上是 rxjs 特定的，与 Angular 无关。