我为键盘驱动的界面做了一个按键服务，我发现它似乎为每个订阅者执行了完整的链： .map((e: KeyboardEvent) => remap(e.keyCode || e.which));
第一个.do()中的console.log执行三次，因为有三个订阅<em
浏览 12提问于2017-03-16得票数 0
回答已采纳
目前，滚动没有触发fromEvent订阅。问题：如何触发var source = Observable.fromEvent(target, 'window:scroll');import {Observable} from "rxjs";
import 'rxjs/add/ob
浏览 2提问于2016-09-07得票数 7
回答已采纳
1回答
我想用RxJS来完成一些我想用英语表达的东西，如：
this.documentClick$ = Observable.fromEvent(document.querySelector('body'), 'mousemove').merge(Observable.fromEvent(document.querySelector('body
浏览 4提问于2016-11-28得票数 2
例如：const mouseMove$ = Observable.fromEvent(document, 'mousemove').pipe(map(it => superExpensiveComputation(it)));由于订阅，这将使
浏览 1提问于2021-10-01得票数 1
回答已采纳
在RxJS中，我希望向每个新订阅者提供最后发出的项。但我如何在一个可观察的链中做到这一点呢？
this.http.get().map().replaySubject().refCount()
浏览 5提问于2017-02-20得票数 3
回答已采纳
可以安全地假设RxJS将按照每个观察者订阅的顺序触发它们的下一个函数。我有一个公共属性为BehaviorSubject的类。对它的第一个订阅将来自类的构造函数中的。我希望确保此私人订阅的下一次订阅在任何其他订阅之前工作。
浏览 12提问于2018-03-06得票数 1
回答已采纳
2回答
我通过依赖注入插入了一个服务组件(组件A)，这个服务组件A不在组件B的模板中。@Output() hostReady = new EventEmitter();hostReady.emit();
浏览 10提问于2017-03-09得票数 4
回答已采纳
我不是100%清楚RxJs 5 share()操作符是如何工作的，请看这里的。问题的Jsbin。如果我创建一个包含0到2的序列的可观察值，每个值被一秒隔开：.take(5)});source.subscribe((n) => console.log(&
浏览 58提问于2016-02-02得票数 40
回答已采纳
我正在使用RxJS，我可以看到在RxJS 5.5.2中有两个可用的函数。.finally是否将被移除，并将其从RxJS 6.0.0放置在wards的side pipe()中是原因还是有任何其他变化？
浏览 1提问于2018-05-10得票数 12
在该函数中，我发出用户输入的关于rxjs主题的数据。我已经在ngOnInit()方法中订阅了该主题。我还有一个rxjs ()运算符，在这个运算符中，我通过一个服务调用天气搜索switchMap(在其中我还将获得城市名称)。现在，当我输入正确的城市名称时，API将使用状态为HTTP200的城市名称触发。在此之后，我还可以输入另一个城市名称，并使用该城市名称触发API。当输入错误的城市名称时，接口会像预期的那样被触发，状态为HTTP 404。但在此之后，当
浏览 0提问于2018-05-14得票数 0
为什么在这个例子中： .pipe( map(item => item * 2), map(item => item - 3), ).subscribe()我原以为输出将是2, 1, 4, 5, 6的。
浏览 1提问于2021-08-25得票数 1
回答已采纳
我的目标是在Ionic 3项目中使用RxJs switchMap，在服务器离线时取消任何正在进行的登录尝试，并且只使用最新的请求。否则，我可以得到一些不必要的异步副作用以后。我试着实现这个代码：<button #submit type="submit">Submit</button>import { Observable } from 'rxjs/Observable';
import 'rxjs/ad
浏览 3提问于2017-09-01得票数 0
回答已采纳
1回答
我有流是由Rx BehaviorSubject的next()方法触发的。如何在订阅者之间共享pipedData$流？我试图在这里使用share运算符，以避免在map运算符内部进行繁重的重新计算，但没有成功-每个订阅者都会产生重新计算。here's stackblitz for this issue 还有可能从来源获取订阅者的数量吗？import { interval, BehaviorSubject } from 'rxjs
浏览 14提问于2020-04-08得票数 0
回答已采纳
是否可以使用.NET Rx Observable.FromEvent方法，或者是否有另一种方法允许在调用第一个订阅方法或调用FromEvent (或类似方法)时只调用add事件处理程序一次，而允许在未订阅观察者时调用因此，我似乎不能使用FromEvent，因为每次调用订阅时，生成的可观察的可观察的事件处理程序都会添加和删除事件处理程序，而观察者则被取消订阅。
在这种情况下，最好的办法是什么？
浏览 0提问于2015-06-08得票数 1
回答已采纳
我创建了一个提供简单GET请求的服务：}
// If we have account cached, use it instead this.accountObservable = this._http.get('http://localhost/api/account')
浏览 7提问于2016-02-27得票数 14
回答已采纳
我想知道像.map()这样的RxJS操作符是如何‘监听’传入的可观察流的。.map()和其他RxJS操作符是否在幕后订阅流，以便访问可观察值？如果我理解正确的话，每个操作符都订阅了输入可观察值，这使它可以访问值流，然后将转换后的值的可观察值返回给下一个操作符？感谢您的任何澄清。
浏览 0提问于2020-10-04得票数 2
1回答
我使用的是Angular2 final ("@angular/core"："~2.1.1“with "rxjs"："5.0.2")。这是我的app.component.ts：import {Observable} from 'rxjs/Observableplaceholder="Search..." >})
浏览 0提问于2017-02-09得票数 1
回答已采纳
2回答
简而言之:如何在流中出现错误后继续侦听，而不将.catch放在每个.subscribe之前假设我有一个主题为当前用户或null。，它只会触发.catch回调，而在订阅和跳过所有成功处理程序和链上的error处理程序。如果在我调用userSubject.next(...)之后，我的所有连锁店和订阅者都能像以前一样工作所以我的问题是:
浏览 1提问于2017-08-03得票数 7
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号