RxJava buffer hasta cambiado
Tengo un observable que emite una gran cantidad de datos como
[1,1,1,2,2,2,3,3,1,1,5,5 ......]
En RxJava podemos usardistinctUntilChanged () para obtener elementos distintos hasta que cambie y resulte como
[1,2,3,1,5, ......]
Del mismo modo, ¿hay alguna manera debuffer los artículos hasta que se cambian? por ejemplo espero una salida como
[[1,1,1], [2,2,2], [3,3], [1,1], [5,5] ......]