保留由 Rxjs 生成的复选框的状态
基于在下拉列表中选择不同的项目，我生成了带有复选框的项目的 html.如何保留复选框的状态，即在下拉列表中的值发生变化时选中/取消选中.在此处查看 plunkr https://plnkr.co/edit/PUG3g7dfTbQjPyIgGLzh?p=preview 步骤: - 取消选中“abc2"- 将 dd 值更改为“国际"- 再次将 dd 值更改为“本地"- 此处必须取消选中“abc
..
rxjs5相关内容
如何在 RxJS5 中恢复 OnError(或类似)
我想使用 RxJS 的 onErrorResumeNext 特性，即即使收到错误也继续接收事件(而不是终止). 但我可以在以下文档中看到 RxJS5 中没有对应关系:https://github.com/ReactiveX/RxJS/blob/master/MIGRATION.md. 是否有使用此类功能的解决方法?谢谢！ 解决方案 我也一直在寻找那个运营商！我想出了一个满足我需
..
RxJS5 TypeScript 打字失败
我在我的项目上运行 tsc，我得到这些与 RxJS5 库相关的错误: $ tscnode_modules/rxjs/observable/FromEventObservable.d.ts(11,39):错误 TS2304:找不到名称“EventTarget".node_modules/rxjs/observable/FromEventObservable.d.ts(11,103):错误 TS23
..
RxJS (5.0rc4):暂停和恢复间隔计时器
我使用 Rx 来保存动画时钟.每个动画帧，它将间隔刻度映射到该刻度的新值. 假设我想暂停动画.最自然的方法是以某种方式暂停时钟 rx，然后在稍后恢复它. 取消订阅然后重新订阅不是一个自然的选择，因为这个动画时钟是一个冷可观察对象.我不想在它们恢复时重新启动动画.如果我寻求一种变通方法，我将不得不生成一个新的简历 rx，这会使所有公开的 API 变得非常复杂. 背压方法似乎没有希望
..
“退订"Observable“执行器"中的函数回调/挂钩；功能
我对“处置"或“取消订阅"函数的目的感到困惑，这是(可选)从可观察的“执行程序"函数返回的，如下所示: const Rx = require('rxjs');const obs = Rx.Observable.create(obs => {//我们在 Observable 的“执行器"函数中obs.next(4);//我们返回这个函数，如果我们取消订阅它就会被调用返回函数(){console.l
..
rxjs 5 中的发布和多播运算符有什么区别?
我正在阅读 rxjs 手册，我对多播和发布操作符之间的区别有点困惑.它们看起来非常相似. 解决方案 我在阅读 http://reactivex.io/rxjs/manual/overview.html.所以要说清楚，.publish() 只是 .multicast(new Rx.Subject())(和 publishBehavior，publishLast 和 publishReplay
..
'可观察的'不是从'Observable<T>'派生的类
当试图从 node_modules 中的类扩展一个类时，打字稿编译器会抛出一个错误说: 属性 'source' 受保护，但类型为 'Observable'不是从'Observable'派生的类. 这仅在基类来自 node_module 时发生. 基类看起来像: import {Observable} from "rxjs/Observable";导出抽象类 TestBase{请
..
在 RxJS 5.5 中测试和模拟可出租操作符
在lettable operator之前，我做了一个helper来修改debounceTime方法，所以它使用了一个TestScheduler: 导出函数 mockDebounceTime(调度程序:TestScheduler，覆盖时间:数字，): 空白 {const originalDebounce = Observable.prototype.debounceTime;spyOn(Obser
..
使用 RxJS 重放带有时间戳的一系列事件
如果我有一个包含 utc 时间戳和事件数据的事件数组，如下所示:[{utcts: , data: , ... ]; 您将如何使用 RxJS 以正确的时间差在数组中的每个项目之间“重放"这些事件?假设数组按 utcts 字段排序，因此第一项具有最低值. 这里有一组非常基本的数据可以开始使用: var testdata = [{utcts: 1, 数据: 'a'},{utcts: 4,
..
基于动作类型及其数据的 ReduxObservable 取消
我有 React 应用程序，它使用 redux-observable 和 typescript.在这种情况下， FetchAttribute Action 被一个 id 触发，然后进行 ajax 调用.在某些情况下，如果“FETCH_ATTRIBUTE_CANCEL"操作使用与“FetchAttributeAction"操作相同的 id 触发，我想取消 ajax 请求. action$.ofTy
..
比较来自多个 BehaviorSubjects 的最新值
说我有这个: isMatchedCountLessThanTotalCountMessage(){//我想实现这个//异步“返回"一个字符串}getMatchedEventsCount() {返回 this.dcs.matchCount.asObservable();}getTotalEventsCount() {返回 this.dcs.totalCount.asObservable();}
..
RxJS Observable &观察者问题
我有一个 Angular 2 服务，它执行几个步骤来验证和登录应用程序用户.每当我尝试在 Observer 上调用 next() 时，都会收到未定义的错误.当 Observable 被实例化时，我唯一可以成功调用 next() 的地方是在构造函数内部. 如果我调用 authenticateUser()，我会收到一个错误，提示 this.isLoggedIn 未定义. AuthServi
..
RxJs:从由 ID 标识的其他流更新列表中的值
我有两个 RX 无限流(我们称它们为 mainValues 和 decoratorValues).名为 mainValues 的一个将元素添加到名为 valueList 的列表中.另一个流 (decoratorValues) 应该为列表中的这些元素分配属性. 两个流中的元素以随机顺序随机到达，我需要以mainValues被放入列表中的任一顺序来解决它尽快，而 decoratorValues
..
未调用可观察订阅
我有一个 Observable，用于将承诺转换为订阅.这会生成一个集合，我需要遍历该集合以在每个元素上调用 HTTP 服务.我正在使用 forkJoin 等待所有这些调用完成，以便我可以做其他事情，但不幸的是，我的订阅没有被调用.你看到我在这里遗漏了什么吗? Observable.fromPromise(this.users.getElements()).subscribe(results =>
..
如何使用 rxjs 定期检查实时连接?
我使用 rxjs 来处理 websocket 连接 var socket = Rx.Observable.webSocket('wss://echo.websocket.org')socket.resultSelector = (e) =>数据 我想定期 (5s) 发送一个 ping 消息并等待 3s 以接收 pong 响应并订阅 a 流，如果没有收到响应. 我尝试过，但没有成功.我承认
..
在 RxJS 中生成具有数据驱动延迟的值流
给定一个包含消息有效负载和时间参数的对象数组，如下所示: var 数据 = [{ message:"1000ms 后交付我", time:1000 },{ message:"2000ms 后交付我", time:2000 },{ 消息:“3000 毫秒后交付我"，时间:3000 }]; 我想创建一个可观察序列，它返回数组每个元素的消息部分，然后等待对象中指定的相应时间量.如果有必要，我
..
从内部 flatMap 通知
这是一个相当复杂的示例: 主要内容: this.runInstructionAndGetResult().subscribe({下一个: val =>console.log(`下一个值:${val}`),错误:val =>console.log(`错误值:${val}`),完成:val =>控制台日志(`完成`)}); 可观察的: public runInstructionAndGet
..
在 RxJs5 中是否有等效于 RxJs<=4#ofArrayChanges
我正在使用 Angular2，我想跟踪数组中的变化，但只有 RxJs5，而且似乎没有这样的功能. 解决方案 没有等效项.Object.observe 提案已从 ES7 中撤回a>，所以在 RxJS 5 中使用 ofArrayChanges 或 ofObjectChanges 没有什么意义.
..
可观察的数组，找到值的索引
我正在编写一个 Angular 应用，它从一个服务中获取一系列商店，作为一个 Observable. 当用户单击地图上的标记时，我想获取位于 Observable 内的数组中商店的索引. stores: Observable;ngOnInit() {this.stores = http.get('URL');}onMarkerClick(事件){const geopoint = event
..
RxJS 订阅内部订阅错误操作
我在 subscribe 中有带有 subscribe 的代码: this.http.post('/update1', newData).subscribe((响应) =>{const r = response.json;const id = r['id'];this.http.post('/update2?id=' + id, newData).subscribe(() =>{this.htt
..