rxjs5

    1热度

    1回答

    我正在使用Nodejs,RxJS和Typescript开发应用程序。 应用程序有它返回一个可观察的字符串 myObsFunction() : Observable<string> { ... do stuff } 我希望能够做一个简单的测试来检查,当我订阅了这个功能我得到预期的字符串的函数。我使用柴和摩卡,所以我写了下面的测试情况 import { expect } from 'chai'

    2热度

    1回答

    我有一个数据流,具有快速传入的数据。我想通过保持顺序将它们插入到数据库中。我有一个数据库,它返回一个承诺,在插入成功时解决。 我想创建一个Rx流,缓冲新数据,直到缓冲数据被插入。 我该怎么做?

    2热度

    2回答

    我有两个可观察: -1-2-3-4-5-6-7-8-9-10-11-12-13-14-15-| -13--14--15--16--17--18--19-----20---------21--------------22------23--24--> 第一个包含一些越来越多,但经过一段时间后停止(这些是来自数据库的光标结果) 第二类是不断涌现越来越多的人首先包含一些数字,但不要停止发射。 (这

    0热度

    1回答

    好吧,所以现在我真的很困惑。执行以下代码 const created = Rx.Observable.create(observer => { observer.next(42) }) const ofd = Rx.Observable.of(42) const createSub = name => [ val => console.log(`${name} rece

    4热度

    1回答

    警告:RxJS newb在这里。 这里是我的挑战: 当onUnlink$观察到发射... 立即开始从onAdd$观察到的捕获值,最多1秒(我会打电话给此分区onAddBuffer$) 。 查询数据库(创建doc$观察到的)来获取我们将使用来匹配的onAdd$值之一 如果从onAddBuffer$观察到的一个值的doc$值相匹配的模式,不排放 如果没有值从onAddBuffer$观察到的doc$值匹

    0热度

    1回答

    我是RxJS的新手。我正在使用RxJs 5.5.2 为了保持简单,我希望每次在主题上调用next时都返回缩小的值。下面是一个示例代码: const sub = new Subject<number>(); const obsesvable = sub.pipe( reduce((a, b) => { return a + b; }, 0) ); obsesvab

    1热度

    1回答

    RxJS版本扫描:5.5.2 我有一个数组const v = [1, 2, 3]; 我希望能够创建此数组中的主体和行为像一个可观察到它消耗1,2,3的值。之后,我想要像一个主题。 这是我遇到麻烦的地方。我需要在每个主题中附加时间上,则初始值v = [1, 2, 3]使用reduce另一个值使用scan 下面是代码: const v = [1, 2, 3]; const sub = new Sub

    2热度

    1回答

    这实际上是自我记录,但它可能对其他人有用。 所以,这里的2个代码和我的小胶质问题: 什么是这两个?: @Effect() loadRegistrationsFailed$: Observable<Action> = this.actions$ .ofType(registrations.LOAD_FAIL) .pipe( map( act

    1热度

    2回答

    RxJS 5.5.2 我有下面的代码谁分裂的数字阵列为对象,具有2个属性“小”的数字越小则4和'大'其余。 const o = from([1, 2, 3, 4, 5, 6]).pipe( scan<number, {}>((a, b) => { if (b < 4) { a['small'].push(b); } else { a['big']

    0热度

    1回答

    如何使用RxJS实现类似以下内容的操作? ABCDEFGH AB CD --- --- --- EF GH 或 ABCDEFGH ABC ---- ----高清GH 我有一个数组,我需要按指定的分区分割并以指定的时间间隔发射值。