JavaScript的Reactive Extensions（RxJS）是一组库，用于使用可观察集合和Array Extras样式组合来编写异步和基于事件的程序。
将Observable的Observable转换为简单的Observable
我是rxjs的新手，已阅读了十几个教程，但它仍然令人困惑。假设我有一个用户ID列表，每3秒我想查询一些数据（在线游戏匹配信息）...
我有两个可以获取给定对象的服务：初始HTTP调用以获取完整列表，websocket通知可以获取新元素的实时更新。我想将两个电话连接到同一个电话......
我有一个服务，从信号器集线器获取更新。这些更新包含所有主题的数据。服务消费者是一些儿童组件，每个儿童组件只对一个感兴趣...
RxJs javascript - bindNodeCallback和一个需要输入参数的Object方法函数
假设我有一个类，例如来自'rxjs / Observable'的import {Observable}; import'rxjs / add / observable / bindNodeCallback'; export class MyClass {name：string; doSomethingWithName（cb :( ...
我有一个可能有嵌套数组的数组。无论有多少'子'阵列，我想总结父母内部的所有数字。为什么不以这种方式工作。其他人抱怨acc1 ......
我正在尝试从同级组件共享一个字符串值（从灯开关切换到导航栏）。我的问题是，当我从DataService发出新值时，属性themeColor没有得到更新。 ...
如何在redux-observable中同时进行多个ajax调用？
我有一个字符串schemaNames = [schemaName1，schemaName2 ...]的数组，对于schemaNames中的每个元素，我想进行一个宁静的调用，以获取模式，我想将结果作为对象... 。
我正在尝试使用重试来实现Angular5 http.get。我写了http.get （'/ api / study'）。retryWhen（（错误：可观察 ）：可观察 => {返回错误....
我正在使用有状态的服务来提问。如果在服务本地状态中存在问题，则它返回它们，否则它从对api的http调用请求它们并存储它们。这种服务方式......
我如何从Save（）方法返回成功。 public SaveItem（）{if（save（））{//目标是使用这样的save方法//关闭弹出窗口; } public SaveAndNew（）{if（save（））{//目标是......
angular5：类型'true'不能分配给'Observable类型
我试图在用户登录component.ts isLoggedIn $：Observable后更改登录状态 ;构造函数（private auth：Auth）{} ngOnInit（）{this.isLoggedIn $ = this ....
使用.forEach和.some比较两个Observable，如数组
我有一个Observable，我异步绑定到视图，我想比较Observable发出的值到另一个Observable，看看它们的任何值是否重叠。我曾是 ...
我想组合/合并多个Observable，并在完成每个Observable时执行finally函数。合并运算符似乎并行执行每个订阅，这就是我...
场景：我有一个网格，我想在其中显示数据。我可能有两个（或更多）行为主题数据源。我还有一个toggle observable，它返回一个数字，表明哪个来源......
Angular RXJS Observables或Subjects在内部传递数字
在Angular 5应用程序（无API）中传递数字的正确RXJS方法是什么？我已经成功传递了一个布尔与Subject：service：import {Injectable}来自'@ angular / core';进口{...
我试图显示来自我的共享服务的数据，但它没有显示。任何人都可以帮助我，我快速的几天结构。我尝试过NgZone和ChangeDetectorRef，但确实'...
Angular CanDeactivate Router Guard具有可观察的订阅值
我一直在尝试编写一个canDeactivate防护来从一个可观察的流中检查一个保存状态并相应地工作。我的服务是来自'@ angular / core'的导入{Injectable};进口{...
我试图用flatMap链接2个订阅，但flatMap中的“this”不是指我的组件，而是指MergeMapSubscriber。在运行时_这是指我的组件，但如果我使用它...
在请求之前，我需要在一个observable中做一些工作，然后让我的拦截方法处理req。我的拦截器类是这样的：@Injectable（）导出类......
我正在尝试理解rxjs publishReplay，refCount和share我想要实现的是缓存http请求，如下所述分享Angular Http结果的正确方法是什么...