使用 RXJS 延迟每个元素
我正在使用 RxViz 来模拟每 1 秒出现一次的不同动作.当我尝试 Rx.Observable.create(obs => {obs.next([1, 2, 3]);//或者可以是 ['aaa', 'bbbb', 'ccc']obs.complete();}).延迟(1000); 在 https://rxviz.com 或者我自己使用 console.log 它一直同时显示三个数
..
rxjs相关内容
RxJS:我怎样才能做一个“如果"?与可观察对象?
假设我有两个 observable，一个我想监听一个 observable 的变化，如果另一个符合某个条件.我用 zip 尝试过，但似乎我只会收到通知，如果 两个 observables 都发生了变化，但是我希望在一个 observable 的每一个变化都收到通知，如果条件另一个是真的. 我尝试了什么: var firstState = new Rx.BehaviorSubject(und
..
Angular2 - 在另一个 Observable 中使用 Observable 返回方法的值
问题 我不知道如何在我的http.get中使用当前返回的getUserHeaders()的Observable的值. 当前错误 输入'Observable'不可分配到类型 'Observable' 预期结果 能够将我的 Observable 返回方法 getUserHeaders() 的值用作 http 调用中的 headers 属性.虽然只返回 http 调用的 O
..
使用 observables 检测 Angular 2 变化
我通常通过浏览现有问题来设法找出我做错了什么，但在这里，没有任何帮助. 我正在使用一个简单的 Ng2 模块来尝试列出和更新 NeDB 存储的内容. 请注意，我对 NeDB 商店没有任何问题，我已确认它已正确更新，并且最初已正确加载，所以我的问题出在别处. 我遇到的问题如下: “异步管道不起作用". 我有这个模块. @NgModule({进口:[CommonModul
..
缺少可观察的方法 RxJS 5.0.0-beta.0
我在使用带有 Angular 2 的 RxJS 时遇到问题.Typescript 定义文件中建议的大多数方法都没有在我的 Observable 对象上定义，例如... 然后我发现，Observable 原型中不存在该方法. 我知道从第 4 版到第 5 版发生了很多变化，所以我错过了什么吗? Browserify 为我添加了它... 解决方案 如果没有看到您的实际代码，我无
..
从 RxJS subscribe() 函数声明一个组件的访问变量
我可以使用 this.variable 来访问组件任何部分的变量，除了像 subscribe() 或 catch() 这样的 RxJS 函数内部. 在下面的例子中，我想在运行一个进程后打印一条消息: import {Component, View} from 'angular2/core';@零件({选择器:“导航器"})@看法({模板:'./app.component.html'，样式:
..
rxjs 只在第一次执行 tap
我只想在我得到第一个发出的值时才执行 tap() 类似于: 可观察的.管道(tap(() => {/* 只有当我得到第一个发出的值时才执行 */})).subscribe(() => {//.....}) 解决方案 您可以在 concatMap 等地图运算符中使用索引.与其他方法不同，这对所选索引是完全灵活的.假设你想要点击第二次发射 index === 1 或任何像 index %
..
如何使用 RxJS observable 去抖动 Angular 4 中的异步验证器?
我正在使用带有 Angular 4 反应式表单的自定义异步验证器来检查电子邮件地址是否已通过调用后端获取. 然而，Angular 会调用验证器，它会为每个输入的字符向服务器发出请求.这会给服务器带来不必要的压力. 是否可以使用 RxJS observable 优雅地消除异步调用? 从'rxjs/Observable'导入{Observable}；从“@angular/forms"导入
..
RXJS 中的 startWith 运算符真的被弃用了吗?
自从更新到 RXJS 版本 6 以来，我的 WebStorm 编辑器一直在抱怨 一些 使用 startWith() 该运算符被标记为已弃用. 您可以在源代码中看到这些方法被标记为已弃用: 主链接(未来更难的链接)莉> 对我来说问题是弃用的警告不一致.有时它会报告不推荐使用的方法，有时则不会.虽然我可以在下面的代码示例中重现警告.好像是在我自己的源代码中随机发生的. 未弃用:
..
RxJs 管道和可出租运算符“map":“void"类型的“this"上下文不可分配给“Observable<{}>"类型的方法的“this"
我有一个非常基本的例子，它使用来自 rxjs@5.5 的可出租运算符 map 和 pipe: import { map } from 'rxjs/operator/map';让 o = of(1, 2, 3, 4).pipe(地图((v) => v * 2)); 但它会产生错误 Error:(34, 5) TS2684:The 'this' context of type 'void' 不可分
..
Angular - 正确使用 RXJS 扩展运算符进行递归 http 调用
我正在尝试使用上一次调用中的值对 Reddit 的 API 进行递归 http 调用.问题是上一个调用在下一个调用开始之前没有完成，所以会进行重复调用.每次调用都应更新“after"值，直到“after"值未定义.我发现了这个 相关帖子 并尝试使用所描述的解决方案，但我不知道如何确保在进行下一次通话之前完成上一次通话.以下是我的实际代码: private getSavedPostsForAuth
..
如何取消订阅/停止 Observable?
我使用以下代码作为计时器: 导出类 TimerService {私人滴答:数字 = 0；私人秒数:数字 = 0；私人计时器；构造函数(秒:数字){this.seconds = 秒；this.timer = Observable.timer(2000, 1000);this.timer.subscribe(t => {this.ticks = t;this.disactivate();});}私人
..
试图理解 RxJS 导入
我很难弄清楚这个导入语句究竟是如何工作的(在一个用 Typescript 编写的 Angular 应用程序中): import 'rxjs/add/operator/toPromise'; 我知道 rxjs 被映射到 SystemJS 配置文件中相应的 node_modules 子文件夹，但后来我卡住了.我看到有一个 index.js 文件，但我不知道这是否或如何帮助解决 add/operat
..
如何在 Angular 中等待守卫
如果我在一条路线上指定三个守卫，似乎所有守卫都会立即被评估. {path: '', component: OptionsComponent, canActivate: [GuardOne, GuardTwo, GuardThree]} 我遇到的问题是我不希望 GuardTwo 在 GuardOne 完成之前运行.有什么办法可以做到这一点吗? 解决方案 我认为这在 4.1.3 中
..
Angular 6:使用 forkJoin 进行错误处理
我不确定在使用 forkJoin 时如何获取特定 api 调用的异常消息 我的代码如下 reqs = [];如果(应该更新电话){reqs.push(this.customerService.updatePhone(phoneUpdateRequest))}如果(应该更新地址){reqs.push(this.customerService.updateAddress(addressUpd
..
使用 WebSocket 可观察的 RxJs
我的 Angular 应用程序使用 websocket 与后端通信. 在我的测试用例中，我有 2 个客户端组件.Observable 计时器按预期打印两个不同的客户端 ID. 每个 ngOnInit() 还会打印其客户端的 ID. 现在由于某种原因，每条消息都会调用 websocketService.observeClient() 的订阅 2 次，但 this.client.id
..
如何在 RxJS 中完成 Observable
假设我们有一个 Observable: var observable = Rx.Observable.fromEvent(document.getElementById('emitter'), 'click'); 我怎样才能让它Complete(什么会为所有订阅的观察者触发onComplete事件)? 解决方案 在目前的形式中，你不能.您的 observable 源自一个不完整的源，因
..
Angular2 Observable BehaviorSubject 服务不工作
我正在尝试创建自己的可观察服务，但是在我从服务中获取初始数据后，对服务的任何更新都不会传播给任何订阅者.服务看起来像这样: import { Injectable } from '@angular/core';从 'rxjs/Rx' 导入 { Observable, BehaviorSubject };@Injectable()导出类数据服务{键:数字[] = [4,5,1,3,2];私人数据:
..
Angular observables - 如果没有订阅，我是否需要取消订阅?
我正在使用最新的 angular 8，并且对 observables 的概念还不熟悉.问题是如果我直接调用一个 observable 而不是将它应用到订阅变量，我是否还需要取消订阅.以下是我想知道是否需要取消订阅的情况?非常感谢提前 场景 1 - 从组件调用 httpService: 服务 - httpServicegetContactsHttp(){让标题:any = new HttpH
..
我应该在 BehaviorSubject 中使用 asObservable 吗?
我想知道 BehaviorSubject 中以下代码中的两种方法是什么. 据我所知: asObservable 方法不仅将其转换为 Observable，还移除了 Observer 实现.因此你不能调用 next, error &在 asObservable() 返回的实例上完成. 但以下内容也让我感到困惑: 通过仅公开 asObservable，您可以使用发出的值，但防止
..