RxJS - lấy n thành phần cuối cùng từ một quan sát được

Question

Tôi muốn lấy 3 phần tử cuối cùng từ một quan sát được. Hãy nói rằng thời gian của tôi trông như thế này:

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

nơi: a, b, c, d, e, f, g, h, i, j are emitted values

Bất cứ khi nào một giá trị mới được phát ra tôi muốn có được nó ngay lập tức, vì vậy nó có thể trông như thế này:

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

Tôi nghĩ rằng điều này cực kỳ hữu ích. Hãy tưởng tượng xây dựng một cuộc trò chuyện mà bạn muốn hiển thị 10 tin nhắn cuối cùng. Bất cứ khi nào một tin nhắn mới đến, bạn muốn cập nhật chế độ xem của mình.

nỗ lực của tôi: demo

Answer 1

Bạn có thể sử dụng scan cho việc này:

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); 

này sẽ in:

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

Các bufferCount sẽ không làm những gì bạn muốn. Nó sẽ phát ra chỉ khi mỗi bộ đệm chính xác là === 3 có nghĩa là bạn sẽ không nhận được bất kỳ phát xạ nào cho đến khi bạn đăng ít nhất 3 tin nhắn.

Answer 2

Bạn có thể nhìn vào Observable#bufferCount chức năng. Một khác biệt là nó muốn ít nhất 3 lần để phát ra (tham số đầu tiên, trong ví dụ này).

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>