RxJS - gözlemlenebilir bir son elemanın son elemanını al

Question

Gözlemlenebilirden 3 son öğe almak istiyorum. benim zaman çizelgesi şöyle diyelim:

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

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

yeni değer bunun böyle bakmak, böylece hemen almak istiyorum yayılan Ne zaman:

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

Bunun çok yararlı olduğunu düşünüyorum. En son 10 iletiyi görüntülemek istediğiniz bir sohbet oluşturmayı düşünün. Yeni bir mesaj geldiğinde, görünümünüzü güncellemek istersiniz.

girişimim: demo

Answer 1

Bunun için scan kullanabilirsiniz:

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

Bu yazdırır:

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

bufferCount istediğini yapmayacağım. Yalnızca her bir arabellek tam olarak === 3 olduğunda yayılacak, bu da en az 3 ileti yayınlayana kadar herhangi bir emisyon elde etmeyeceğiniz anlamına gelir.

Answer 2

Sen Observable#bufferCount fonksiyonu bakabilirsiniz. Bir fark, en az 3 kez yayılmasını istemesidir (bu örnekte ilk parametre).

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>