如何将 Observable<T> 的第一个元素添加到每个组？

Question

假设我有Observable<String> playerNames，其中第一个元素是标题。如何将其分解为多个块（同时为每个组添加标题）？

playerNamesObservable
     .window(100)
     .to(chunk -> { return playerNamesObservable.concatWith(chunk) }

headerObservable 基本上是playerNamesObservable.first()

问题是我想非常小心发射项目（不想使用blockingGet等）

谢谢

Answer 1

使用publish:

recordsObservable.publish(shared -> {
    Observable<String> first = shared
        .take(1)
        .replay()
        .autoConnect(0);

    return shared.skip(1)
        .window(100)
        .map(w -> w.startWith(first));
})
.flatMap(chunk -> /* consume each chunk */)