rxjs5

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回答

rxjs創建可觀察的超時總是錯誤

好吧，所以現在我真的很困惑。執行以下代碼 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：如何將多個嵌套的觀測數據與緩衝區結合使用

警告：RxJS newb在這裏。這裏是我的挑戰：當onUnlink$觀察到發射... 立即開始從onAdd$觀察到的捕獲值，最多1秒（我會打電話給此分區onAddBuffer$）。查詢數據庫（創建doc$觀察到的）來獲取我們將使用來匹配的onAdd$值之一如果從onAddBuffer$觀察到的一個值的doc$值相匹配的模式，不排放如果沒有值從onAddBuffer$觀察到的doc$值匹

0熱度

1回答

使用reduce主題沒有完成調用

我是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回答

RxJS管道如何工作（可出租操作員）

這實際上是自我記錄，但它可能對其他人有用。所以，這裏的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 - 按分區分割並使用iterval發射

如何使用RxJS實現類似以下內容的操作？ ABCDEFGH AB CD --- --- --- EF GH 或 ABCDEFGH ABC ---- ----高清GH 我有一個數組，我需要按指定的分區分割並以指定的時間間隔發射值。

1熱度

1回答

使用chai和mocha在nodejs中觀察結果的簡單測試

我正在使用Nodejs，RxJS和Typescript開發應用程序。應用程序有它返回一個可觀察的字符串 myObsFunction() : Observable<string> { ... do stuff } 我希望能夠做一個簡單的測試來檢查，當我訂閱了這個功能我得到預期的字符串的函數。我使用柴和摩卡，所以我寫了下面的測試情況 import { expect } from 'chai'