在SUBSCRIBE内呼叫SUBSCRIBE好吗？
我需要从三个不同的API向一个函数传递三个数据： this.service.service1().subscribe( res1 => { this.service.service1().subscribe( res2 => { this.service.service1().subscribe( res3 => { this.funcA(res1, res2, re
..
rxjs相关内容
如何实现嵌套二级路由并仍然从孩子那里获取数据?角 6
..
每次触发 setInterval 时 Observable.of(array) 都会更新
在使用 Observable.of(array) 和 Angular 的异步管道时，我遇到了一些奇怪的行为.也许我用错了，但我无法理解. 我在 Ionic 3(角度 4)中有一个 view.html 和 view.ts 文件.我正在做一个 Observable.of(items).Items 只是一个包含对象的数组.在我看来，我有:异步的.这一切都很好，但是当我每 1000 毫秒在 view
..
离子 2 http.get() 问题
我尝试使用这两种方法进行 http.get() 调用. 第一: getResults(){返回 this.http.get('http://localhost/api.php').承诺().then(数据=>数据.json());} 错误显示: 3 122412 错误例外:未捕获(承诺中):响应状态为:0 对于 URL:null4 122413 错误原始堆栈跟踪:5 122413 错误
..
RXJS:向 Observable 添加一个函数以在订阅时执行(延迟)
向 Observable 添加一个函数，以便在订阅时执行(延迟) 我有一个由事件组成的 Observable.在这种情况下，蓝牙通知. 我只想在有人订阅该 Observable 时运行一个函数 (startNotifictions). 此代码在以前的版本中确实有效.它与 Ionic3 框架一起使用.它添加了一个新的运算符，在订阅时运行.现在转译器的类型有问题，抱怨两次，即 .do
..
FormControl debounceTime 在角度 5(离子 3)中不可用
我刚刚将 ionic 应用程序中的 Angular 从版本 4 更新到了 5.我有一些搜索 FormControl 输入，允许用户通过 ajax 请求搜索数据库.我使用 debounceTime() 方法来延迟 ajax 搜索请求，但在角度升级后，此方法不再可用.我删除了这个方法调用，但现在在 android 上的每个用户按键都会发出一个新请求. 还有其他方法可以实现这种延迟吗? this
..
Rxjs 订阅方法被忽略
在将其标记为重复之前，请注意这些都不适合我:问题1/问题2/问题3 因此，在收到对上一个问题 我按照 上的所有内容开始使用 rxjs指南我得到了 但是，由于未触发 subscribe 方法，我很快又在过去几个小时内再次陷入困境. 我的服务编码如下: import { Injectable } from '@angular/core';从'rxjs/Subject'导入{主题}；
..
如何以最大并行请求数发送 1000 个 XHTTP 请求
我有一个 Angular 应用程序，它需要发送 N 个 XHTTP 请求，其中 1
..
Ionic 4 本机插件地理定位给了我“找不到模块:错误:无法解析 'rxjs/Observable'"
我正在尝试在 ionic 4 中使用 ionic 原生插件 geolocation 但出现此错误: 编译失败. ./node_modules/@ionic-native/geolocation/index.js 未找到模块:错误:无法解析“rxjs/Observable"'C:\Projects\ionic\prayers\node_modules\@ionic-native\geol
..
以角度每 x 秒发出一次 http 请求
我正在尝试在 angular2 中每 x 秒刷新一次 http 调用. ionViewDidLoad() {让 loader = this.LoadingController.create({'内容':'请稍候'});loader.present().then(()=>{this.http.request('http://mywebserver.com/apps/random.php').ma
..
Rxjs: take(1) 用法
我看过一个关于rxjs的教程是这样的. 我的问题是: 1)这里的take(1)有什么用?我在网上看到很多解释，但我真的不明白.此外，我没有看到在此代码中使用 take(1) 的任何好处.并且作者确实在 REST api 相关服务中的每个返回函数上都使用了 take(1). 2) 订阅后作者没有退订.是不是因为作者使用 take(1) 所以不需要手动取消订阅? 3) 如果我想实现
..
带有角度 http 请求的异步管道的好处
很多角度教程都建议使用异步管道来自动取消订阅 observable. 他们声称的: 异步管道用于自动取消订阅观察者，否则您需要手动取消订阅 他们做了什么: 他们使用 angular http 调用 REST api 作为 async 管道的示例. 但是，据我了解，角度 HTTP 会自动取消订阅 observable.因此，异步管道实际上并没有达到预期目的，因为即使没有异步管道
..
在 Angular2 & 中使用分页服务Ionic2 使用 Observables
我有一个远程集合 接口 Foo {id:字符串；属性:任何；} 我可以使用 a 类 FooAPIService {find(skip = 0): 承诺{//承诺最多 5 Foos.要获得更多信息，请使用 skip >1//分页是服务器端}on(event: string, callback: (foo: Foo) => any) {//注册事件处理程序，用于事件:创建、更新、删
..
Angular 测试随机中断:“未捕获的类型错误:您在预期流的位置提供了‘未定义’."
我们有一个中等大小的 Angular 应用程序，目前有大约 700 个单元测试.几周前，完美的测试开始打破.更奇怪的是:运行两次测试会产生不同的结果，即不同的测试可能会中断.在控制台中，我们总是发现错误: 未捕获的类型错误:您在预期流的位置提供了“未定义". 但堆栈跟踪没有提示错误的根源实际位于何处(请参阅本文末尾).堆栈跟踪显示与 mergeMap 运算符的连接，但事实证明，我们在应
..
从 Observable 中过滤掉项目的单元测试 (Jasmine/RxJS)
我正在使用 Jasmine/Karma 对 Angular 服务进行单元测试.我想确认我的服务正确过滤了项目. 例如，如果我有一项服务可以让超过一定年龄的人，它 应该返回超过最低年龄的人(正面案例) 不应退回未满最低年龄的人(否定情况) 这是我正在努力测试的 #2. 服务: getPeople(minAge: number): Observable
..
Angular 单元测试 TypeError:this.http.get(...).pipe 不是函数
我正在按照这个示例对服务进行单元测试(从 spring 应用后端获取请求)https://angular.io/guide/testing#testing-http-services 服务等级: @Injectable()出口类关税服务 {构造函数(私有messageService:MessageService，私有http:HttpClient){}public getTarifs():
..
如何在不使用 TestBed 的情况下在 Angular 中模拟 http 帖子?
如何对这个登录功能进行单元测试，特别是 http post 部分?我制作的 http 模拟未正确编码以进入代码的“if...else"部分.我不想使用 TestBed.TestBed 太慢了. login(username: string, password: string): Observable{常量标头 = 新标头()；headers.append('Content-Ty
..
Rxjs toPromise 行为与 observable 不同
我有一个简单的例子，其中两个方法创建并返回一个承诺.第二个方法buildRedCar() 调用第一个方法buildCar()，修改promise 返回的值并从自身返回另一个promise.代码然后调用 buildRedCar()，并且只是 console.logs 结果.这在转换为 Promise 时不起作用，但在使用直接 observables 时确实起作用. 不起作用: import
..
RXJS:交替组合流的元素
我想交替组合多个流的元素: var print = console.log.bind(console);var s1 = Rx.Observable.fromArray([1, 1, 5]);var s2 = Rx.Observable.fromArray([2, 9]);var s3 = Rx.Observable.fromArray([3, 4, 6, 7, 8]);替代(s1，s2，s3)
..
我可以在“subscribe()"之前捕获某些错误吗?在 Angular2 中可观察的 RXJS 中?
在允许子类订阅到Angular2中的observable之前，基类是否有可能catch某些错误. 例如 导出类 SomeBaseClass {构造函数(私有_http:Http，私有_location:位置){}protected _fetchData(url): Observable{const 标头 = 新标头()；headers.append('Authorization', 'To
..