在 ngrx 中获取当前状态
这里在 ngrx 中获取当前状态的解决方案.这个例子很简单——你只需要使用take(1).但是在 take 的 rxjs 文档中它说: 返回指定数量的从一个开始的连续元素可观察序列 为什么取第一个值会得到当前状态(即最后一个值)? 此外，我在使用 Subject 进行单元测试时无法模拟这种行为. 解决方案 ngrx-store 是 length=1 的 ReplaySub
..
observable相关内容
展平嵌套的 Observable
我被困在嵌套的可观察地狱中，可以用手做. 我有以下代码块 return this.findUser(term).map( users => {return users.map( user => this.getLastLogin(user.user_id).map( last_login => {user.last_login = last_login;返回用户；}));}); find
..
Angular2 - 在另一个 Observable 中使用 Observable 返回方法的值
问题 我不知道如何在我的http.get中使用当前返回的getUserHeaders()的Observable的值. 当前错误 输入'Observable'不可分配到类型 'Observable' 预期结果 能够将我的 Observable 返回方法 getUserHeaders() 的值用作 http 调用中的 headers 属性.虽然只返回 http 调用的 O
..
使用 observables 检测 Angular 2 变化
我通常通过浏览现有问题来设法找出我做错了什么，但在这里，没有任何帮助. 我正在使用一个简单的 Ng2 模块来尝试列出和更新 NeDB 存储的内容. 请注意，我对 NeDB 商店没有任何问题，我已确认它已正确更新，并且最初已正确加载，所以我的问题出在别处. 我遇到的问题如下: “异步管道不起作用". 我有这个模块. @NgModule({进口:[CommonModul
..
如何取消订阅/停止 Observable?
我使用以下代码作为计时器: 导出类 TimerService {私人滴答:数字 = 0；私人秒数:数字 = 0；私人计时器；构造函数(秒:数字){this.seconds = 秒；this.timer = Observable.timer(2000, 1000);this.timer.subscribe(t => {this.ticks = t;this.disactivate();});}私人
..
使用 WebSocket 可观察的 RxJs
我的 Angular 应用程序使用 websocket 与后端通信. 在我的测试用例中，我有 2 个客户端组件.Observable 计时器按预期打印两个不同的客户端 ID. 每个 ngOnInit() 还会打印其客户端的 ID. 现在由于某种原因，每条消息都会调用 websocketService.observeClient() 的订阅 2 次，但 this.client.id
..
如何在 RxJS 中完成 Observable
假设我们有一个 Observable: var observable = Rx.Observable.fromEvent(document.getElementById('emitter'), 'click'); 我怎样才能让它Complete(什么会为所有订阅的观察者触发onComplete事件)? 解决方案 在目前的形式中，你不能.您的 observable 源自一个不完整的源，因
..
Angular2 Observable BehaviorSubject 服务不工作
我正在尝试创建自己的可观察服务，但是在我从服务中获取初始数据后，对服务的任何更新都不会传播给任何订阅者.服务看起来像这样: import { Injectable } from '@angular/core';从 'rxjs/Rx' 导入 { Observable, BehaviorSubject };@Injectable()导出类数据服务{键:数字[] = [4,5,1,3,2];私人数据:
..
Angular observables - 如果没有订阅，我是否需要取消订阅?
我正在使用最新的 angular 8，并且对 observables 的概念还不熟悉.问题是如果我直接调用一个 observable 而不是将它应用到订阅变量，我是否还需要取消订阅.以下是我想知道是否需要取消订阅的情况?非常感谢提前 场景 1 - 从组件调用 httpService: 服务 - httpServicegetContactsHttp(){让标题:any = new HttpH
..
类型“对象"上不存在属性“".可观察订阅
我刚刚开始使用 Angular2，但遇到了一个我无法真正理解的问题. 我创建了一些模拟数据: export const WORKFLOW_DATA: Object ={“测试数据阵列":[{ key: "1", name: "Don Meow", source: "cat1.png" },{ key: "2", parent: "1", name: "Roquefort", source:
..
RxJS observable，它从第一次发射开始发射前一个值和当前值
我有一个 BehaviorSubject，它会定期发出 JavaScript 对象.我想构建另一个 observable，它将发出基础 observable 的先前和当前值，以便比较两个对象并确定增量. pairwise() 或 bufferCount(2, 1) 操作符看起来很合适，但它们只有在缓冲区被填充后才开始发射，但我需要这个 observable 从底层 observable 的第
..
完成后重复请求 (Angular2 - http.get) n 秒
我玩弄了 angular2，过了一会儿就卡住了. 使用 http.get 对单个请求工作正常，但我想每 4 秒轮询一次实时数据，经过一段时间的修补并阅读了很多我最终得到的 reactx 内容: Observable.timer(0,4000).flatMap(() =>this._http.get(this._url).分享().map(this.extractData).catch(th
..
使用 RxJS 链接 promise
总的来说，我是 RxJS 和 FRP 的新手.我的想法是将 ExpressJS 应用程序中现有的承诺链转换为可观察的实践.我知道这可能不是最好的例子，但也许有人可以帮助阐明. 我正在做的事情: 我有两个承诺 - prom1 和 prom2 我希望 prom1 在 prom2 之前运行 如果 prom1 发送一个拒绝(错误)，我想在它开始之前取消 prom2. 我希望 prom1
..
Angular 2 - 订阅 Observable.fromEvent 错误:“无效的事件目标"
我在尝试订阅 Observable 时遇到一个奇怪的错误. 这里是出现问题的代码的淡化版本: import {Component, Input, OnInit, ViewChild} from '@angular/core';从 'rxjs/Rx' 导入 Rx；@零件({选择器:'动作概述-描述'，模板:需要('./actionOverviewDescription.html')})导
..
缺少 rxjs 平面图
我尝试链接多个 rx.js observables 并传递数据.Flatmap 应该是拟合运算符，但导入了 import { Observable } from 'rxjs/Observable'; 未找到: 错误 TS2339:属性 'flatmap' 在类型 'Observable' 上不存在 使用的是 rx.js 的 5.0.0-beta.6 版本. public getCurre
..
Angular 2:如何使用 Observable 过滤器
我有一个像这样调用 API 的服务: 返回 this._http.post(appSettings.apiUrl + 'SomeController/SomeAction', params, {withCredentials: true, headers: this.headers}).timeoutWith(appSettings.maxTimeHttpCalls, Observable.de
..
使用 Observable 检测变量的变化
我想我误解了 Observable 应该如何使用.我想放入一个值，当值改变时它应该发出新值.我认为这就是它们的用途，但所有教程和文档似乎都没有这样做，但与此同时，我总是看到它们以这种方式应用.例如，在 angular 中，当您订阅“FirebaseListObservable"时，当 firebase 中的值发生变化时，它会触发订阅中的快照.我想为我自己的变量做那个.假设我只有一个字符串变量，当它
..
“rxjs"observable.throw 不是函数 - Angular4
我一直在学习 Angular 4，一切都很顺利，直到我尝试在服务中实现捕获处理.我正在尝试使用“rxjs"捕获并抛出，但我的控制台中有一个未定义的函数错误. import { Injectable } from '@angular/core';从“@angular/http"导入{ Http}；从 'rxjs/observable' 导入 { Observable };导入 'rxjs/add/
..
如何从angular2中的observable获取数据
我正在尝试使用 rxjs 在 Angular 中打印 http 调用的结果 考虑下面的代码 import { Component, Injectable, OnInit } from '@angular/core';从“@angular/http"导入 { Http, HTTP_PROVIDERS };导入'rxjs/Rx'；@Injectable()类 myHTTPService {构造函
..
使用 Angular RxJs Observables 处理多个 http 请求并等待所有请求完成
我正在使用 Observables，我有一个用例: 我必须从给我 Page[] 的服务中获取“页面"对于每个“页面"，我必须从其他服务中获取“部分" 此外，在订阅所有这些“部分"时，我必须根据返回的数据执行一些操作. 担心的是，一旦所有这些请求都完成了，就必须采取一些行动. 解决方案 你需要使用mergeMap和forkJoin 当使用 forkJoin 时，你可以同
..