RxJS 中的管道是什么?
我想我有基本的概念，但还有一些晦涩之处 所以总的来说，这就是我使用 Observable 的方式: observable.subscribe(x => {}) 如果我想过滤数据，我可以使用这个: import { first, last, map, reduce, find, skipWhile } from 'rxjs/operators';observable.pipe(地图(x
..
rxjs5相关内容
最后在订阅上观察
根据这篇文章，onCompletesubscribe 的 和onError 函数是互斥的. 意味着 onError 或 onComplete 事件将在我的 subscribe 中触发. 我有一个逻辑块，无论我收到错误还是成功完成信息流，都需要执行该逻辑块. 我在 python 中查找了类似 finally 的东西a>，但我发现的只是 finally 需要附加到我创建的可观察对象.
..
如何使用 rxjs 在 angular2 中实现输入 keyup 事件的去抖动服务
我正在尝试在输入按键事件时调用服务. HTML 下面是onKeyUp()函数 onKeyUp(event) {让 observable = Observable.fromEvent(event.target, 'keyup').map(value => event.target.value).去抖动时间(1000).distinctUntilChanged().flatMap((搜索
..
如何让一个可观察对象立即返回数据，之后每 5 秒返回一次
我想创建一个从 webapi 返回数据的 observable.我希望它立即返回数据，并每 10 秒轮询一次 API.下面的代码显示我正在使用“间隔"方法.但这会使第一组数据延迟 10 秒.我如何在没有初始延迟的情况下让第一次数据刷新? export class EventService {公共事件$:Observable;私人_eventsObserver:观察者；私人投票间隔:数字 = 50
..
“扁平化"的最佳方式RxJS Observable 中的数组
我的后端经常在 RxJS 5 Observable 中以 数组的形式返回数据(我使用的是 Angular 2). 我经常发现自己想要使用 RxJS 运算符单独处理数组项，我使用以下代码 (JSBin): const dataFromBackend = Rx.Observable.of([{ name: 'item1', active: true },{名称:'item2'，活动:假}，{名
..
.unsubscribe 和 .take(1) 的区别
我想知道，当 unsubscribe 之后使用 unsubscribe 时，使用 .take(1) 和 .unsubscribe 之间是否有任何性能差异订阅: var observable = Rx.Observable.interval(100); 首先: var subscription = observable.subscribe(function(value) {控制台日志(值)；}
..
不同 RxJS 主题的语义是什么?
该主题的文档很少，很难在那里找到“切入点". 解决方案 语义因主题类型而异.我将它们分为两种:普通(Rx.Subject)和特殊用途的主题(其他三种).由于其专业化(例如，完成/重新连接行为)，特殊目的主题共享原版主题的部分语义，但有一些警告. Vanilla Rx.Subject 语义 主要功能 主体实现了观察者、可观察接口(以及一次性接口，因为它们的原型上有一个 di
..
在 RxJS 中链接 Observable
我正在学习 RxJS 和 Angular 2.假设我有一个包含多个异步函数调用的 promise 链，这些调用依赖于前一个的结果，如下所示: var promiseChain = new Promise((resolve, reject) => {setTimeout(() => {解决(1)；}, 1000);}).then((结果) => {控制台日志(结果)；返回新的承诺((解决，拒绝)=
..
如何在一部史诗中处理多种动作类型?这样做有什么缺点吗?
对 redux-observables、rxjs 和 observables 来说是个新东西.想知道我如何处理另一个动作，在同一个史诗中说“ActionTwo" const Epic1 = (action$,store) =>{返回 action$.ofType('ActionOne').mergeMap((action) => {return ajax({'method': 'GET', 'u
..
在 redux-observable 中使用 fetch 而不是 ajax
在 redux-observable 中是否可以使用 isomporphic-fetch 而不是 Rx.DOM.ajax? 解决方案 (注意:RX.DOM.ajax 来自 RxJS v4，不能与redux-observable 需要 RxJS v5.v5 中的等价物是 Rx.Observable.ajax 或 import { ajax } from 'rxjs/observable/aj
..
RxJS:takeUntil() Angular 组件的 ngOnDestroy()
tl;dr:基本上我想将 Angular 的 ngOnDestroy 与 Rxjs takeUntil() 运算符结合起来.-- 这可能吗? 我有一个 Angular 组件，可以打开多个 Rxjs 订阅.这些需要在组件销毁时关闭. 一个简单的解决方案是: class myComponent {私人订阅A；私人订阅B；私人订阅C；构造函数(私人服务A:服务A，私人服务B:服务B，私人服
..
如何每隔一段时间发出HTTP请求?
我对 angular 和 rxjs 很陌生.我正在尝试创建一个 angular2 应用程序，它从静态提供的文本文件(本地服务器上)获取一些数据，我想使用 Angular2 的 http 提供程序和 rxjs 的地图在固定时间检索并映射到数据模型 interval(5000).反映对提供的 txt 文件的任何更改. 使用 rxjs 4.x 我知道你可以使用 Observable.interva
..
如何从内部具有 Observable 订阅的函数返回值?
我不知道如何从 Observable 中提取值以由存在 Observable 的函数返回.我只需要从它返回一个值，别无其他. 当前有效的版本 function getValueFromObservable() {this.store.subscribe((数据:任何)=>{控制台日志(数据)})}getValueFromObservable() 我需要这个工作，函数返回值，然后: fu
..
Hot 和 Cold observables:是否有“hot"和“cold"运算符?
我查看了以下 SO 问题:什么是热和冷可观察值? 总结: 当一个冷的 observable 有一个观察者来消费它们时，它会发出它的值，即观察者接收到的值的序列与订阅时间无关.所有观察者都将使用相同的值序列. 热 observable 发出与其订阅无关的值，即观察者接收到的值是订阅时间的函数. 然而，我觉得热与冷仍然是混淆的根源.所以这是我的问题: 默认情况下所有 rx o
..
如何将我自己的 RxJS Subject 双向绑定到 [(ngModel)]?
是否有一种简短而简单的方法来传递 RxJS 主题 或 BehaviorSubject 用于双向绑定的 Angular 2 指令?很长的路要走如下: @Component({模板:``}) 我希望能够做这样的事情: @Co
..
如何将 rxjs 运算符应用于从 angularfire2 获得的数据
假设我像这样在 angularfire2 中请求数据: var ref = new Firebase("firebase url"); 现在如何将 rxjs 运算符(如 map 运算符)应用于即将到来的数据 解决方案 我不认为你在看 angularfire2 - 那是 v1 代码... 您可以在 angularfire2 中使用 rxjs 运算符 - 数据作为 Observabl
..
错误 rxjs_Observable__.Observable.forkJoin 不是函数?
我在 angualr-cli 应用程序中使用 Rxjs. 在viewer.component.ts中 //其他导入从 'rxjs/Observable' 导入 { Observable };//为简洁起见省略导出类 ViewerComponent 实现 OnInit、AfterViewInit、OnDestroy {someFunction(someArg){//为简洁起见省略让 some
..
错误 TS2339:“Observable<boolean>"类型上不存在属性“partition"
以前我使用 rxjs-5，我使用 observable.partition 如下: const [isTiming$, isNotTiming$] = this.store.select(state => state.tetris.isTiming).partition(value => value); 将 angular 升级到 8 后 rxjs 升级到 rxjs-6 开始抛出以下错误:
..
如何在 rxjs 的订阅中重构订阅
例如: this.saveSubscription$ = this.ds.onSave$.subscribe(x =>this.sb.updateMachineTool(this.viewEditModel.viewEditModel).subscribe(x = {console.log('警报结果', x)})) this.ds.onSave$ 是当点击不同组件上的保存按钮时触发的主题.
..
如何在 rxjs 的订阅中重构订阅
例如: this.saveSubscription$ = this.ds.onSave$.subscribe(x =>this.sb.updateMachineTool(this.viewEditModel.viewEditModel).subscribe(x = {console.log('警报结果', x)})) this.ds.onSave$ 是当点击不同组件上的保存按钮时触发的主题.
..