我有一個 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）。