未使用mergeMap执行完整回调时的RxJS
我想知道为什么下面示例中的onComplete回调从不执行。如预期的那样执行下一个回调。如果我在foo创建的可观察对象中抛出错误，也会执行错误回调。只有完整的回调不会被执行。 JSBin：http://jsbin.com/punoridajo/edit?html,js,console,output let button = document.getElementById('click-
..
rxjs5相关内容
RXJS:TypeError:this._subscribe 不是函数
我正在将 ionic 3.8 应用程序迁移到 3.9.2.此迁移包括对 RXJS 5.5 的更新 我现在遇到了这个错误: TypeError: this._subscribe 不是一个函数.(在'this._subscribe(sink)'中，'this._subscribe'是t的一个实例) 经过几个小时的调试，我发现这部分代码与错误有关: 受保护的observeConnec
..
RXJS 5 .subscribe() 不带参数
所以一个快速的问题.我已经使用 RxJS 5 几个月了，我遇到了一些我不太了解的行为，因为我无法在任何地方查找它. 我的情况是，使用简单的 .subscribe(); 订阅可观察链不会触发可观察. 但是，如果我添加一个 onNext 回调(是否为空)，可观察触发器和链处理:.subscribe(() => {}); 谁能解释为什么会发生这种行为? 解决方案 感谢 Dami
..
为什么 switchMap 不取消前一个观察者?
我在组件(控制器)中描述了方法: public requestPassportData(): void {const th = 这个；常量数据 = {get_scanned_data: 真};Observable.timer(0, 1000).switchMap(() => this.requestMethods.requestPassportData(data)).takeWhile(() =
..
RxJS 中是否存在与“race"运算符相反的运算符?
我有两个可观察对象，我想听最后一个发出第一个值的可观察对象，是否有操作符?类似的东西: let obs1 = Rx.Observable.timer(500,500);让 obs2 = Rx.Observable.timer(1000,1000);//我想要这个值让懒惰 = Rx.Observable.sloth(obs1,obs2); sloth observable 会从 obs2 发出值
..
Angular HTTP Interceptor 如何链接一个 observable
我正在使用 Azure AD adal 库进行身份验证.有一个调用来获取一个返回一个可观察的令牌.如何将这个 observable 添加到拦截中?在下面的例子中，如何让订阅中设置的请求作为 Observable 返回? intercept(request: HttpRequest, next: HttpHandler): Observable>{this.authAzureService.get
..
RxJS5 随着时间的推移发出数组项并永远重复
我想随着时间的推移发出数组项(每次发出之间有 1 秒的间隔)，当所有项都发出后，一遍又一遍地重复. 我知道怎么做，但我想知道是否有比 .. 更简洁的东西. const MY_ARRAY = ['one','two','three'];const item$ = Rx.Observable.interval(1000).take(MY_ARRAY.length).repeat().map(x
..
RXJS 控制 observable 调用
我在我的 Angular 2 项目中使用 RxJs 版本 5.我想创建一些 observables 但我不希望立即调用 observables. 在第4版中，您可以使用(例如)Controlled 命令或 可暂停缓冲区.但该功能不是(还没有) 在版本 5 中可用. 我怎样才能在 RxJs 5 中获得这种功能? 我的最终目标是将创建的 observable 排入队列并一一调用它们.
..
subscribe 有什么作用，它与 Observable 有什么关系?
我是 Angular 的新手，我遵循的教程有术语“Observable".导师解释了，但我没有完全理解. 什么是Observable，为什么我们总是要调用observable.subscribe()? subscribe() 实际上是做什么的? 解决方案 什么是 Observable? 一个 Observable 可以看作是一个数据源.该数据可能存在(或不存在)并且可能会
..
RxJs:有损形式的 zip 运算符
考虑使用 zip 运算符将两个无限的 Observable 压缩在一起，其中之一它发出项目的频率是另一个的两倍. 当前的实现是无损的，即如果我让这些 Observable 发射一个小时，然后我在它们的发射率之间切换，第一个 Observable 最终会赶上另一个. 随着缓冲区越来越大，这将在某些时候导致内存爆炸. 如果第一个 observable 将发射项目数小时，而第二个将在最后发射一个项
..
测试 rxjs 的正确方法
我带来了“rxjs in action"这本书，刚刚完成了测试部分. 测试 rxjs 代码与通常的测试不同，因为一切都是延迟加载. 在书中，他们提到了两种测试方法，要么通过 done(我使用 QUnit 和 done 信号异步代码完成)或大理石图. 我的问题是，我应该选择上面提到的哪种方法? 解决方案 我经常从同事那里得到这个问题.我终于开始记录我的方法在我的博客上测试
..
如何在一个简单的 RxJS 示例中不使用主题或命令式操作来管理状态?
我已经用 RxJS 试验了两个星期了，虽然原则上我喜欢它，但我似乎无法找到并实现管理状态的正确模式.所有文章和问题似乎都同意: Subject 应该尽可能避免，以支持通过转换来推送状态； .getValue() 应该完全弃用；和 .do 也许应该避免除了 DOM 操作? 所有这些建议的问题在于，除了“您将学习 Rx 方式并停止使用 Subject"之外，似乎没有任何文献直接说明您应
..
RxJS - .subscribe() 与 .publish().connect()
这主要是 RxJs 最佳实践/方法问题，因为我的 POC 代码有效，但我是 RxJs 的新手. 问题归结为 .subscribe() 与 .publish().connect()，因为它们似乎都在做同样的事情. 在我的 angular2 应用程序中，我有一个按钮调用一个函数来注销用户，它调用我的服务中的一个函数来执行一些服务器端操作并返回一个 URL 以将用户重定向到.为了发起请求，我
..
订阅多个 Observables(比如在 Promises 中链接 then())
我的 Angular 2 应用程序在一个服务中有 2 个方法(GetCategories() 和 GetCartItems())，并且这两个方法都返回 Observables. 为了从我的组件中依次调用这两个方法，我编写了以下代码: ngOnInit(){this.appService.GetCategories().subscribe((数据) => {this.appService.
..
什么是 observable、observer 和 subscribe ?
我正在学习 angular，但我对这些 observable、observer 和 subscribe 感到困惑事物.所以请解释一下. 解决方案 这是一个简单的视觉效果，可以看出区别: 如上所示......Observable 是一个事件或数据流.它们通常从 Angular 方法返回，例如 http.get 和 myinputBox.valueChanges. 订阅“启动"可观
..
Angular2 2.0.x 和 Rx 5 beta.12 包
我目前正在更新我的项目的依赖项，该项目使用 Angular2 npm 包，因此也使用 RxJs.我正在更新到依赖 Rx5 beta.12 的 2.0.2 稳定版 angular.对于我的 Web 应用程序，我只部署 Rx.min.js 包并在我的 index.html 文件中使用脚本标记加载它.这种方法之前在 Rx umd 包中运行良好，但同时会导致错误，因为在我看来，RxJs 的贡献者为了一个公
..
RxJs Subject.subscribe 方法没有按预期工作
Subject.subscribe 方法在调用时输出以下错误: TypeError: 无法读取未定义的属性“_subscribe"在 BidirectionalSubject._subscribe (Rx.js:10239)在 BidirectionalSubject._subscribe (Rx.js:10239)在 BidirectionalSubject.Observable.subscr
..
使用 Subject.create 创建的主题无法取消订阅
我有一个负责订阅某些 observable 的主题: var timer$ = Rx.Observable.timer(1000, 2000); 当主题像那样链接到主题时 var timerSubject = new Rx.Subject;定时器$.subscribe(timerSubject);var subscription1 = timerSubject.subscribe(n =>
..
在 rxjs 中执行高级 http 请求
我有以下对象: 类问题{idQuestion:字符串；问题:字符串；类型问题:字符串；}类答案{idAnswer:字符串；idQuestion:字符串；答案:字符串；}类选项{idOption:字符串；idQuestion:字符串；选项;} 我想填充以下对象: class QuestionOptionsAnswer {问题:问题；答:答；选项:选项[]；} 目前，我对每种对象都有一个服务，
..
如何在零时间内获取 RxJS Observable 事件?
我正在将 Observable 的所有事件收集到一个 data 数组: const obs$ = Rx.Observable.间隔(500).take(4);让数据 = [];const start = performance.now();obs$.subscribe(值 =>{数据推送({时间:performance.now() - 开始，数据:值});},() =>{},() =>{co
..