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

    好吧,所以現在我真的很困惑。執行以下代碼 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 我有一個數組,我需要按指定的分區分割並以指定的時間間隔發射值。

    1熱度

    1回答

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