3

いくつかの数値を発行する Observables があり、単に最後の N 要素を取得したいだけです。

次のコードがあります(RxJavaの単なるラッパーであるRxKotlinを使用しています):

val list = listOf(1,2,3,4,5,6,7,8,9,10)
Observable.fromIterable(list)
          .buffer(3, 1)
          .lastOrError()
          .subscribe{value -> println(value)}

残念ながら、結果は です[10]。バッファ演算子が返すものをよく見ると、次のようになりました。

[1, 2, 3]
[2, 3, 4]
[3, 4, 5]
[4, 5, 6]
[5, 6, 7]
[6, 7, 8]
[7, 8, 9]
[8, 9, 10]
[9, 10]
[10] 

最後の「フル」バッファを取得する方法はありますか -> [8, 9, 10]?

4

1 に答える 1