Rxjs：創建Observable，這是另一個可觀察的延遲偏移

Question

是否有一種簡單的方法來創建另一個偏移的observable？

例如，假設Observable1發出[1,2,3,4,5]。

我將如何從Observable1創建Observable2使得Observable2發射[1,2,3,4]（因此，它發射什麼時候Observable1發出1，它發出1時Observable1發射2等）

Obs1開始 ------- 1 -------- 2 ---------- 3 ------------ 4 ---- --------- 5 ----------------->

Obs2開始 --------------- --1 ---------- ------------ 2 3 4 ------------- --------- -------->

謝謝！

Answer 1

您可以使用bufferCount和map運營商做你想要什麼：

const source = new Rx.Subject(); 
 
const offset = source.bufferCount(2, 1).map(values => values[0]); 
 

 
source.subscribe(value => console.log(`source = ${value}`)); 
 
offset.subscribe(value => console.log(`offset = ${value}`)); 
 

 
source.next(1); 
 
source.next(2); 
 
source.next(3); 
 
source.next(4); 
 
source.next(5);

.as-console-wrapper { max-height: 100% !important; top: 0; }

<script src="https://unpkg.com/rxjs/bundles/Rx.min.js"></script>

bufferCount(2, 1)將發出一個雙值每次收到值時間緩衝 - 一次有兩個緩衝區中的值，即。因此，緩衝區中的第一個值將被一個源發射所抵消。

你可以用bufferCount(2, 1)替代pairwise()，它可以做同樣的事情。