RxJS - 관측 가능한 마지막 원소를 받아 들인다.

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 기능을 볼 수 있습니다. 한 가지 차이점은 적어도 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>