RxJS - 観測対象から最後のn個の要素を取り出す

Question

観測対象から最後の3つの要素を取りたいと思う。のは、私のタイムラインは、このようになっていることを言ってみましょう：

--a---b-c---d---e---f-g-h-i------j->

場所：a, b, c, d, e, f, g, h, i, j are emitted values

新しい値が、私はそれがこのように見えることができますので、すぐにそれを取得したい放出されるたび：

[a] 
[a, b] 
[a, b, c] 
[b, c, d] 
[c, d, e] 
[d, e, f] 
[e, f, g] 
[f, g, h] 
... and so on 

これは非常に便利だと思います。最後に10件のメッセージを表示するチャットの構築を想像してみてください。新しいメッセージが来るたびに、あなたのビューを更新したい。

私の試み：demo

Answer 1

あなたはこのためscanを使用することができます。

Observable.from(['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', 'k', 'l', 'm', 'n', 'o', 'p', 'q', 'r', 's', 't', 'u']) 
    .scan((acc, val) => { 
    acc.push(val); 
    return acc.slice(-3); 
    }, []) 
    .subscribe(console.log); 

これが印刷されます：

[ 'a' ] 
[ 'a', 'b' ] 
[ 'a', 'b', 'c' ] 
[ 'b', 'c', 'd' ] 
[ 'c', 'd', 'e' ] 
... 
[ 's', 't', 'u' ] 

bufferCountはあなたがやりたいことはありません。各バッファがちょうど=== 3である場合にのみ放出されます。これは、少なくとも3つのメッセージを投稿するまで放出されないことを意味します。

Answer 2

あなたはObservable#bufferCount機能で見ることができます。 1つの違いは、少なくとも3回発光させたいということです（この例では最初のパラメータ）。

const source = Rx.Observable.interval(1000); 
 
const example = source.bufferCount(3,1) 
 
const subscribe = example.subscribe(val => console.log(val));

<script src="https://unpkg.com/@reactivex/rxjs@5.4.3/dist/global/Rx.js"></script>