rxjs5

2热度

1回答

我还在学习RXJS（刚开始），我知道我的问题是首发。我正试图结合来自外部电话的两个响应。假设我做了call1和call2，我应该可以订阅一个联合响应。下面是我的代码 var arrayWeather =['http://apidev.accuweather.com/currentconditions/v1/250111.json?language=en&apikey=hoArfRosT1215'

0热度

2回答

如果rxjs观察到检查结束

我有一个类实例化时，使得一些Web服务调用，下面的伪代码： Rx.Observable.fromPromise(jQuery.getJSON('https://api.github.com/users')) .flatMap(function() { return Rx.Observable.fromPromise(jQuery.getJSON('https://api.github.

0热度

1回答

如何避免productId不同时覆盖事件？

我有一个产品清单。每个产品都有一个id和description。 <div *ngFor="let product of products"> <input type="text" [ngModel]="product.description" (ngModelChange)="onEdit($event, product.id)"> </div> editStream: Even

2热度

1回答

Property'onNext'在类型'BehaviorSubject <Filer>'

上不存在我创建了一个angular2应用程序，我有一个服务，我希望能够在一个组件中写入，然后在其他组件中读取/更新它组件（路线）。这里是我的服务看起来像目前： import { Injectable } from '@angular/core'; import { Filer } from './filer.model'; import { Observable } from 'rxjs/O

0热度

1回答

与异步代码扫描操作

我通常使用扫描是这样的： Observable.interval(10).take(10).scan((acc, x) => acc.concat(x), []).subscribe... 现在，在扫描的第一个参数，而不是一个同步方法我想通过该获取（ACC的方法中，x ）并返回新的acc的可视化。（例如，一种保存为dB的方法，并将保存的对象与来自db的信息（如修订号，然后添加到累加器中）一起返回

2热度

1回答

RxJS .next（）在Angular 2中默默地失败App

我正在尝试编写一个基本的角度2应用程序，它使用RxJS的新版本 - >“rxjs”：“5.0.0-beta.6”。我按照cookbook的指示尝试做出通知服务，我的应用程序的任何部分都可以调用它来显示消息。我遇到的问题是，当我拨打.next()添加下一个通知时，订阅不会收到此问题。拨打newNotification后，this.displayMessage(notification);行不会运

0热度

1回答

RxJS5 Mongo问题

我有一些使用mongo执行查询的RxJS代码。在RxJS v4中运行正常，但是当我迁移到v.5时，我遇到了问题。下面是一些简单的代码： // Get a mongo connection getDb() { var connect = Rx.Observable.bindNodeCallback(mongodb.connect) return connect(this.op

5热度

2回答

rxjs 5中发布和多播运营商有什么区别？

我正在阅读rxjs手册，对于多播和发布操作员之间有什么区别，我有点困惑。他们看起来非常相似。

0热度

1回答

类型错误：未知类型返回

我正在使用ngrx/effects。我得到这个错误： ORIGINAL EXCEPTION: TypeError: unknown type returned 这是我的代码部分： this.store.dispatch({ type: CHAT_LOAD_MESSAGES, payload: chatId }); @Effect() loadMessages$ = this.updat

3热度

1回答

当页面更改时，可以触发加载所有存储状态的内容是什么？

我正在使用ngrx/store,ngrx/effects和ngrx/router。我的影响是这样的： @Effect() loadOneProduct$ = this.updates$ .whenAction(LOAD_ONE_PRODUCT) .switchMap(() => this.productService.loadOneProduct()) .map(o