Rxjs

1. 首页
2. Rxjs

javascript – RxJs：zip运算符的有损形式

考虑使用zip运算符将两个无限的Observable压缩在一起,其中一个Observable发出的项目频率是另一个的两倍.当前的实现是无损耗的,即如果我让这些Observables发射一小时然后我在它们的发射速率之间切换,第一个Observable将最终赶上另一个.随着缓冲区越来越大,这将导致内存爆炸.如果第一个observable将发出几个小时的项目而第二个将在最后发出一个项目,则会发生同样的情况.如何为此操作符实现有损行为？

javascript – RxJs将流分成多个流

如何根据分组方法将永不结束的流拆分为多个结束流？).这意味着需要在窗口之前将发射延迟一个(这是第一个.bufferCount(2,1).map(arr=>arr[0]).或者也许用publish()更容易控制订阅的顺序：输出是一样的.

javascript – RxJs 5共享()运算符如何工作？

它不是100％清楚我如何RxJs5共享()运算符工作,看到这里latestdocs.Jsbin的问题here.如果我创建一系列0到2的可观察值,每个值分隔一秒：如果我创建两个订阅者可观察到：我在控制台中得到这个：我认为每个订阅将订阅相同的可观察,但似乎并非如此！但是如果将share()运算符添加到sourceobservable中：然后我们得到这个：没有share(),我会期望什么.这里发生了什么,share()运算符如何工作？

javascript – RxJS中的“map”方法是什么意思？

我以为是使用地图将click事件的集合转换为另一个事件集合集合.过滤器很容易理解,它就像过滤器一样,只采取我感兴趣的事件,并跳过其他.但是在事件的背景下地图呢？如果它意味着“将集合转换为另一个集合”就像数组版本一样,为什么当#btn点击时仍然会触发？我的意思是我将它映射到另一个集合,现在它不再是#btn的点击事件的集合,但它是一个新的集合的东西…

Typescript构建从node_modules文件夹获取错误

我正在运行一个typescript构建并在node_modules中获取错误.为什么不忽略这个文件夹？我在tsconfig.json的exclude部分.真的很奇怪的是,我有另一个项目,我已经做了一个文件比较,它不会抛出这些错误,即使gulpfile.js,tsconfig.json和node_modules文件夹是相同的.还可以检查什么？

javascript – rxjs可观察的变化间隔

至少,世界肯定需要更多的RxJs例子！解决方法您可以使用Subject以及switchMap和interval来动态控制周期.每当主题发出一个值时,该值可用于指定间隔的周期：

javascript – 如何将节点可读流转换为RX observable

如果我有一个Nodejs流,例如来自process.stdin或fs.createReadStream之类的东西,我如何使用RxJs5将其转换为RxJsObservable流？我看到RxJs-Node有一个fromreadableStream方法,但看起来它在近一年内没有更新.解决方法对于任何寻找此项的人,请遵循Mark的建议,Iadaptedrx-nodefromStreamimplementa

javascript – 错误TS2339：带有Angular2的类型’HeroService’上不存在属性’handleError’

好吧,伙计们,抱歉这个问题,因为我知道有几个已经有关于编写的Typescript,但我遇到了这个问题,我无法连接点.我正在尝试按照Angular2TourofHeroes应用程序,并尝试用thechapteronHttp完成它,但我的hero.service.ts文件输出此错误：我从这里的其他问题中了解到,这很可能与Typescript的配置方式有关,但似乎没有这个问题的一致原因.我不熟悉Type

javascript – 为什么我们应该使用()函数的RxJs？

解决方法他们使用()的原因是因为它很容易使用它而不是真正的HTTP调用.在实际应用程序中,您将实现这样的getHeroes(),例如：但是,由于您只想使用模拟响应而不创建任何真正的后端,您可以使用()返回虚假响应：你的应用程序的其余部分将工作相同,因为()是一个Observable,你可以稍后订阅或链接运算符,就像你使用this.http.get(…).()的唯一作用是它在订阅时立即将其参数作为单个排放发出,然后发送完整的通知.

javascript – RxJS油门行为;立即获得第一个价值

p=preview我知道rxjs有这3种节流方法：auditTime(),throttleTime()和debounceTime()我正在寻找的行为是默认情况下lodash执行的一个节流：>1)马上给我第一个值！p=preview注意我将您的lodash版本更新到最新版本.在lodash4.7中,我重写了油门/去抖操作符来修复一些边缘案例错误.您使用的是4.6.1仍有一些错误,但我认为它们不会影响您的测试.