я есть наблюдаемая, которая излучает большое количество данных, таких как

[1,1,1,2,2,2,3,3,1,1,5,5 ......]

В RxJava мы можем использоватьdistinctUntilChanged () чтобы получить отдельные предметы, пока он не изменился, и это приведет к

[1,2,3,1,5, ......]

Точно так же есть способбуфер детали пока не поменялись? например, я ожидаю, что выход

[[1,1,1], [2,2,2], [3,3], [1,1], [5,5] ......]