对连续项目使用 RXJava groupby

Question

我有一个 observable 可以解析大型 csv 文件（无法放入内存）并发出如下元素：

[{id=1, childId=1}, {id=1, childId=2}, {id=1, childId=3}, {id=2, childId=5}, {id=2, childId=6}, {id=1, childId=23}, {id=1, childId=18}]

一行一行。

使用 groupBy 时，我的输出类似于

[{id=1, childs=1,2,**323, 18**}, {id=2, childs=5,6}]

groupBy 似乎很正常。但是我需要的是接收连续项目的分组元素，所以我想在另一个元素中接收 id=1 的最后一个项目。总共，我想收到 3 个元素。

所以我想以连续的方式接收同一个键的一个 observable，当我有一个不同的键时，我想接收另一个 observable（group by）。