rxjs5

10热度

2回答

我试图轮询一个RESTful端点来刷新我的实时聊天消息。我知道实时聊天的最佳方法是Websockets，我只是想了解RxJS如何与Angular 2配合使用。我想每秒钟检查一次新邮件。我有以下代码： return Rx.Observable .interval(1000) .flatMapLatest(() => this.http.get(`${AppSettings.AP

2热度

2回答

如何将主体转换为RxJs中的Observable 5

如何将主体转换为RxJs 5中的Observable？例如，当我们想要公开主题以进行订阅，但不希望控制对其调用next()时，此功能非常有用，并且更愿意将新值的发布保留为私有。的文档（见here）提到这样的事情： var subject = new Rx.Subject(); var obs = subject.asObservable(); 但RxJs 5目前这不起作用（阿尔法8），我

19热度

2回答

RxJs 5 share（）运算符是如何工作的？

对于我来说，它不是100％清楚如何RxJs 5 share()操作员工作，请参阅这里latest docs。 Jsbin的问题here。如果我创建一个可观察到的一系列的0至2，一秒分隔每个值： var source = Rx.Observable.interval(1000) .take(5) .do(function (x) { console.log('some side ef

9热度

2回答

shareReplay in RxJS 5

根据RxJS 5 MIGRATION.md，看起来shareReplay()已被删除。为什么？ .publishReplay(1).refCount()是否忠实地复制了该行为？基本上我需要重播最新的单个数据集给任何新的用户。

5热度

2回答

Angular 2 RxJS检查延迟后的鼠标事件是否仍然有效

我正在使用Angular 2来制作一个指令。我有以下事件绑定到主机组件： host: { '(mouseenter)': 'onMouseEnter($event)', '(mouseleave)': 'onMouseLeave($event)' } 我还创建了有关该指令的两个流和听众来管理这两个事件 export class PopupDirective {

2热度

1回答

Angular2 Observable

我想运行第一次认证http get函数，一旦成功，然后运行另一个函数，然后返回Observable，所以可以订阅并继续与其他方法一起使用。 return new Observable(observer => { this.api .login(username, password) .subscribe( data => {

16热度

1回答

RxJS轮询行更新的无限滚动

我在https://www.youtube.com/watch?v=zlERo_JMGCw 29:38 看着马修Podwysocki事件在那里，他解释它们是如何解决的Netflix的滚动。用户滚动更多的数据，因为之前的数据被清理并且更加累加（但是回滚显示先前的数据）。我想做的事相似，但我抓住了Netflix的演示代码： function getRowUpdates(row) { var

4热度

1回答

复杂的RxJS迭代器只有可见的行

我们在每个请求列表中有超过500行，有时它是10，有时它是巨大的。我想获取该数组，只显示屏幕上可见的内容并隐藏其他所有内容，但用户向下滚动将显示其他行并隐藏以前的内容。这有点复杂，我在观看RxJS视频和Netflix做了类似的事情。我不确定使用什么函数来产生这种效果。 https://gist.github.com/iBasit/8ceef1db9de945a37559 Netflix示例。

23热度

5回答

如何使用@ ngrx/store获取State对象的当前值？

我的服务类在调用Web服务之前需要从我的状态获取名为dataForUpdate的属性。目前，我正在做这样的： constructor (public _store: Store<AppState>, public _APIService:APIService) { const store$ = this._store.select ('StateReducer');

0热度

2回答

使用Rxjs5（Beta）来限制http请求

我使用的是RxJS5（https://github.com/ReactiveX/RxJS），我试图访问Riot API，每10分钟有500个请求，每10秒有10个请求。我建立了一个请求对象流，我有一个用户准备好接收它们并实际请求它们，但是我在RxJS上有点新，并且不确定我应该使用哪个运算符来限制请求。