rxjs5

    0热度

    2回答

    在RxJS 4.0我可以做一些事情如下: let clicks = Observable.fromEvent(board.canvas, 'click'), keydowns = Observable.fromEvent(document, 'keydown') .filter((e) => e.keyCode === 32); return Observable

    0热度

    1回答

    尝试使用RxJS v5构建计划,其中某些事件可以触发计划重新加载。目前使用3个来源 - schedule $,event $和userNotification $(以下示例)。 我已经尝试了许多不同的策略,并且在reloadSchedule事件时间到达时,我一直会像recursive reloads一样变得怪异。下游数据(事件$)是否有办法干净地触发上游(计划$)重新加载,而没有任何行动/通知滞留

    4热度

    2回答

    我想借此可观察到的< T [] >并将其转换为可观察到的<Ť>,使得来自每个阵列的可观测< T [] >被分解和然后通过Observable <T>单独发射阵列的各个元素。 有没有这样做的标准操作符?我搜查了四周,但还没有找到任何东西。谢谢。 被指向concatMap/flatMap的方向后,我想出了以下的一般解决方法: var source: Observable<T[]>; ... var

    0热度

    2回答

    我想用rxjs5运行this example。但它不起作用。我已拨打#41 line。它说地图返回Subject并且它没有.takeUntil方法。实施它的最佳方式是什么?谢谢

    13热度

    1回答

    我一直在使用RxJS两个星期,尽管我原则上喜欢它,但我似乎无法找到并实现管理状态的正确模式。所有文章和问题显得不以为然: Subject应尽量避免使用有利于刚经由转换推状态; .getValue()应该完全弃用;和 .do或许应该避免,除了DOM操作? 所有这些建议的问题是,没有文学的出现,直接说,你应该用什么来代替,除了“你会学习的Rx的方式,并停止使用主题”。 但是我无法在任何地方找到一个直接

    0热度

    1回答

    我有一个类扩展角Http类,我们称之为MyHttp。 我也有MyJwtHttp类延伸MyHttp类。 我希望能够返回响应。JSON的问题是,如果我做这样的事情: myJwtHttp.request(..).map(res=>res.json() 和request方法的实现是: class MyHttp extends Http { request(url,...){ ..

    3热度

    3回答

    我刚刚通过npm i [email protected]安装了rxjs 5 beta 3。使用TS-节点例如当 import {Observable} from "rxjs" new Observable(o => o.next(42)).filter(() => true); 此代码编译非常清楚: 我有以下示例代码。 但是,在IntelliJ IDEA中查看此代码时,找不到filter(

    4热度

    2回答

    看来在rxjs 4.x中,Rx.Observable.fromCallback接受作用域作为第二个参数,但在5.0中,此方法更改为Rx.Observable.bindCallback,并且没有接受范围参数。如何在bindCallback中添加范围参数。例如在ES6中。 class Test { constructor(input) { this.input = input;

    1热度

    1回答

    /** * Created by darius on 02/04/16. */ import { Component } from 'angular2/core'; import { Observable } from 'rxjs/Rx'; @Component({ styles: [ require('../../style.css') ], selector:

    0热度

    1回答

    我搜索了很多,试图看d.ts文件,但仍然不明白什么是错的。找不到RxJs5如何使用此功能的示例。 var source = Observable.fromEvent(document.body, 'keypress'); var delayedSource = source.delay(1000); var obs = source .buffer(()