Buffer RxJava até ser alterado
Eu tenho um observável que emite um grande número de dados como
[1,1,1,2,2,2,3,3,1,1,5,5 ......]
No RxJava, podemos usardistinctUntilChanged () para obter itens distintos até que ele mude e isso resultaria em
[1,2,3,1,5, ......]
Da mesma forma, existe uma maneira deamortecedor os itens até serem alterados? por exemplo, espero uma saída como
[[1,1,1], [2,2,2], [3,3], [1,1], [5,5] ......]