RXJS groupBy Observable <Object[]>
我有 entries$: Observable;: 我想按groupId对它们进行分组.我是这样试的: groupBy(books => books.map(book => book.groupId)),mergeMap(innerObs => innerObs.skip(1).map(books => books.map(book => book.groupTitle))); 然而，它
..
observable相关内容
Angular RxJS Observable:takeUntil 与使用订阅取消订阅
有几种方法可以取消订阅 Angular 组件上的 observables(通过使用 ngOnDestroy).应首选以下哪个选项?为什么(例如技术原因、性能等)? 选项 1:takeUntil 使用 RxJS takeUntil 取消订阅 @Component({选择器:“应用程序航班"，templateUrl: "./flights.component.html"})导出类 Fli
..
RxJS 中的 ThrottleTime 与 debounceTime 之间有什么区别以及何时选择哪个?
我正在尝试了解 throttleTime 与 debounceTime 以及在什么时候使用哪个? 我有一个 upvote 按钮，可以向后端(计算投票)发出 API 请求.用户可以多次提交按钮，但我想限制每秒可以按下按钮的次数. 我知道 throttleTime 和 debounceTime 操作符可以做到这一点，但我应该选择哪一个? const upvoteClicks = from
..
Angular:从 FileReader 返回 Observable/ES6 Promise
我试图从 FileReader 返回结果，我发现 this 实施.但是因为它已经过时了，我想知道如何使用 ES6 Promises 或 Rx Observables 来实现它. 以下是我参考上述链接的代码，它按预期工作. import { Injectable } from '@angular/core';从 'xlsx' 导入 * 作为 XLSX；从 'xlsx' 导入 * 作为 XLS
..
如何使用 RXJS Observables 轮询服务?
给定以下代码，如何更改它以使对“api/foobar"的获取请求每 500 毫秒重复一次? 从“RxJS/Rx"导入{Observable}；从“@angular/core"导入{Injectable}；从“@angular/http"导入{Http}；@Injectable() 导出类 ExampleService {构造函数(私有http:Http){}getFooBars(onNext:
..
TypeScript - 等待 observable/promise 完成，然后返回 observable
我对 TypeScript 很陌生 &RxJS，我试图在另一个 Observable 完成后返回一个 Observable: public myObservable = () : Observable=>{console.log('检索数据库中的令牌');返回 Observable.create(观察者 => {setTimeout(() => {观察者.下一个(真)；观察者.完成()；}, 5
..
如何在 Angular 2 中发出 2 个依赖的 http 请求
我需要发出 2 个 http 请求(第二个依赖于第一个)以将用户凭据插入到我的数据库中. 第一个服务获取用户凭证(http://localhost:55978/FleetViewDBWebService.asmx/ChekCreds?name=name1&subname=subname1) 并检查用户是否已经存在，如果存在则返回“ID"，如果用户不存在则返回“ok". 然后我需要订阅第
..
为什么我们应该在 Angular 中使用 subscribe() 而不是 map() ?
我试图利用 angular2 中的 observables 并且对为什么我应该使用 map() 而不是 subscribe() 感到困惑.假设我从 webApi 获取值，就像这样 this.http.get('http://172.17.40.41:8089/api/Master/GetAllCountry') 现在使用 subscribe(success, error, complete)
..
RXJS Observable 数组的简单过滤器
我使用 Angular2 开始我的项目，开发人员似乎推荐使用 RXJS Observable 而不是 Promises. 我已经实现了从服务器检索元素(史诗)列表.但是如何通过使用例如 id 来过滤元素? 以下代码是从我的应用程序中提取的，现在显示了最终的工作解决方案.让我们希望它可以帮助某人. @Injectable()导出类 EpicService {私人网址 = CONFIG.
..
RxJs 从 observable 中获取价值
在组件中: singleEvent$: Observable; 在初始化时，我可以观察到 this.singleEvent$ = this._eventService.events$.map(函数(事件){让 eventObject = events.find(item => item.id === eventid);让 eventClass: Event = new Event(event
..
如何将来自 http.get 的响应映射到 Angular 2 中类型对象的新实例
我试图了解如何使用 Angular 2 中的 http.get 和 Observables 将服务调用的结果映射到对象. 看看这个 Plunk 在 getPersonWithGetProperty 方法中，我期望返回一个 PersonWithGetProperty 类型的 Observable.然而！我无法访问属性 fullName.我想我必须创建类 PersonWithGetProp
..
无需订阅即可从 Observable 获取当前值(只需要一次值)
如何在不订阅的情况下从 Observable 中获取当前值?我只想要一次当前值，而不是它们进来时的新值. 解决方案 您需要使用 BehaviorSubject, BehaviorSubject 与 ReplaySubject 类似，只是它只记住最后一次发布. BehaviorSubject 还要求您为其提供默认值 T.这意味着所有订阅者都会立即收到一个值(除非已经完成). 它
..
在 ngFor 和 Async Pipe Angular 2 中使用来自 Observable 对象的数组
我想了解如何在 Angular 2 中使用 Observables.我有这个服务: import {Injectable, EventEmitter, ViewChild} from '@angular/core';从“rxjs/Observable"导入{Observable}；从“rxjs/Subject"导入{Subject}；从“rxjs/Rx"导入{BehaviorSubject}；从
..
Angular 2 Http、Observables 和递归请求
我有一个 REST 端点，它返回一个项目列表，一次最多 1000 个项目.如果有超过 1000 个项目，响应的 HTTP 状态为 206，并且有一个 Next-Range 标头，我可以在下一个请求中使用它来获取更多项目. 我正在开发Angular 2 应用程序，并尝试使用Http 和Observable 来实现它.我的问题是我不知道如何根据项目的页数合并多个 Observable 并最终返回
..
angular2 rxjs 可观察 forkjoin
是否可以继续 forkjoin http.get 请求，即使其中一个请求失败. 我正在 angular2 中寻找类似 $q.allSettled 的函数. 参见示例:http://jsfiddle.net/Zenuka/pHEf9/ angular.module('qAllSettled', []).config(function($provide) {$provide.decora
..
如何在订阅 Angular 4 中返回值
我是角度观察的新手.我有一个问题，我想在 subscribe 方法中返回一个值.我有以下方法 (getFirebaseData(idForm:string):observable ): getTotalQuestions(idForm:string){让总问题:数量；this.getFirebaseData(idForm+"/Metadatos").订阅(项目=>{items.map(item
..
如何从订阅返回 observable
当我在订阅者中获得某个值时，我试图返回一个 observable，但我失败了. 这是代码: canActivate(route: ActivatedRouteSnapshot, state: RouterStateSnapshot):Observable{//获取要激活的路由this.routeToActivate = route.routeConfig.path;//获取用户访问级别返回
..
rxjs 中的 flatMap、mergeMap、switchMap 和 concatMap?
请大神解释一下SwitchMap和FlatMap在Javascript方面的区别(角度角度，rxjs 5) 据我所知. SwitchMap 只发出最新的 observable 值并取消之前的 observable. flatMap 收集所有单独的 observable 并将所有 observable 返回到单个数组中，而无需关心 observable 的顺序.异步工作. c
..
使用 Observables 合并子数组
我有这个数据结构: [{编号:1，名称:“项目1"，子项目:[{编号:1，名称:“子项目 1"},{编号:2，名称:“子项目 2"}]}, {编号:2，名称:“项目2"，子项目:[{编号:3，名称:“子项目 3"}, {编号:4，名称:“子项目 4"}]}] 我对网络服务进行以下调用以获取项目:this.dataService.get("items") 返回的是一个 Observable
..
类型错误:您提供了一个预期流的无效对象.你可以提供一个 Observable、Promise、Array 或 Iterable
我正在尝试从服务调用中map，但出现错误.查看 订阅未在 angular 2 中定义? 并说为了订阅，我们需要从运营商内部返回.我也有 return 语句. 这是我的代码: checkLogin(): Observable{返回 this.service.getData().地图((响应) =>{this.data = 响应；this.checkservice = true;返回真；},(
..