observable相关内容
..
Java 8 流是否类似于 RxJava 可观察对象? Java 8 流定义: 新 java.util.stream 包中的类提供了 Stream API支持对元素流进行函数式操作. 解决方案 简答 所有序列/流处理库都为管道构建提供了非常相似的 API.不同之处在于用于处理多线程和管道组合的 API. 长答案 RxJava 与 Stream 完全不同.在所有
..
在 StackOverflow 上遇到与许多人相同的问题后,我无法理解什么是“外部角度区域"服务? 我已经检查了有关该主题的所有现有问题,这正是我需要问这个问题的原因: https://github.com/angular/angular/issues/5150 Angular2:视图未从在订阅中 https://blog.thoughtram.io/angular/2016/02
..
在使用 Observable.of(array) 和 Angular 的异步管道时,我遇到了一些奇怪的行为.也许我用错了,但我无法理解. 我在 Ionic 3(角度 4)中有一个 view.html 和 view.ts 文件.我正在做一个 Observable.of(items).Items 只是一个包含对象的数组.在我看来,我有:异步的.这一切都很好,但是当我每 1000 毫秒在 view
..
向 Observable 添加一个函数,以便在订阅时执行(延迟) 我有一个由事件组成的 Observable.在这种情况下,蓝牙通知. 我只想在有人订阅该 Observable 时运行一个函数 (startNotifictions). 此代码在以前的版本中确实有效.它与 Ionic3 框架一起使用.它添加了一个新的运算符,在订阅时运行.现在转译器的类型有问题,抱怨两次,即 .do
..
..
我习惯于将 $q 与 angular 1 一起使用.我正在迁移到 angular 2. 是否有提供 .when() 方法的等价物? 例如我需要迁移这个: .service('updateProDB', ['$rootScope','连接状态','$q','存储服务','sendToServer','$ionicPopup',功能($rootScope,connectionStatus
..
我有一种情况,我需要从 Ionic 2 应用程序的存储中获取一段数据,然后使用该数据创建一个 HTTP 请求.我遇到的问题是 SqlStorage 方法返回承诺,而 http 方法返回一个 observables.我必须做这样的事情才能让它工作: getToken() {return this.storage.get('token').then((token) => {this.token =
..
根据这个答案如何在rxjs中返回一个空的observable 我已经尝试了所有方法,但对我没有用 这是我的代码 post(url):Observalbe{if(this.holder.nullConnection()){//检查网络连接//返回空的observalbe返回 Observable.empty() ;}别的{返回 this.http.post(this.configu
..
我正在构建一个使用 Firebase 和 AngularFire2(目前处于 alpha 阶段)的实验性(Ionic 2)应用程序.为此,我以 Aaron Saunders 的本教程为基础: http://www.clearlyinnovative.com/integrating-firebase-with-angularfire2-into-angular2-ionic2-part-2ht
..
我试图通过使用 forkjoin 来避免嵌套的 observables.当前(嵌套)版本如下所示: this.http.get('https://testdb1.firebaseio.com/.json').map(res => res.json()).subscribe(data_changes => {this.http.get('https://testdb2.firebaseio.co
..
我正在使用 Jasmine/Karma 对 Angular 服务进行单元测试.我想确认我的服务正确过滤了项目. 例如,如果我有一项服务可以让超过一定年龄的人,它 应该返回超过最低年龄的人(正面案例) 不应退回未满最低年龄的人(否定情况) 这是我正在努力测试的 #2. 服务: getPeople(minAge: number): Observable
..
loadAdList$ 是一个利用 actions$ 流的 Observable: loadAdList$: Observable= 这个.actions$.ofType(adActions.LOAD).switchMap((动作) => {return Observable.fromPromise(store.findAll('ad', action.payload).then
..
在 Angular 2 中对返回 Observable 结果的服务进行单元测试的正确方法是什么?假设我们在 CarService 服务类中有一个 getCars 方法: ...导出类 CarService{...getCars():Observable{返回 this.http.get("http://someurl/cars").map( res => res.json() );}.
..
observable、ObservableObject 和 Model 有什么区别?谢谢. 解决方案 Model 继承自 ObservableObject,而 ObservableObject 继承自 Observable. Observable 提供对事件的支持 - 绑定、解除绑定和触发方法. ObservableObject 提供更改跟踪.由数据源和 MVVM 框架使用. M
..
我有一个非常标准的 API 分页问题,您可以通过一些简单的递归来处理.这是一个虚构的例子: public Observable>扫描() {返回 scanPage(Optional.empty(), ImmutableList.of());}私有 ObservablescanPage(可选 startKey,List结果){返回 this.scanner.scan(startKey, LIM
..
我有一个简单的例子,其中两个方法创建并返回一个承诺.第二个方法buildRedCar() 调用第一个方法buildCar(),修改promise 返回的值并从自身返回另一个promise.代码然后调用 buildRedCar(),并且只是 console.logs 结果.这在转换为 Promise 时不起作用,但在使用直接 observables 时确实起作用. 不起作用: import
..
在允许子类订阅到Angular2中的observable之前,基类是否有可能catch某些错误. 例如 导出类 SomeBaseClass {构造函数(私有_http:Http,私有_location:位置){}protected _fetchData(url): Observable{const 标头 = 新标头();headers.append('Authorization', 'To
..
将我的 Angular 项目从版本 5 更新到 6 后,出现此错误: 类型 Observable' 不可分配给类型 Observable'. 在我的 todo.service.ts import { Injectable } from '@angular/core';从'@angular/common/http' 导入 { HttpClient };从'../../../enviro
..
效果: @Effect()loadDocsEffect$ = this.actions$.pipe(ofType(myActionTypes.LoadDocs),mergeMap(action => this.myService.getDocs()),地图(数据 => 新的 LoadDocsSuccess(数据)),catchError(error => Observable.of(new Lo
..