Окно RxJava2, буфер с индикатором - PullRequest
Новая
       9

Окно RxJava2, буфер с индикатором

0 голосов
/ 26 ноября 2018 
[ "start-a", "during-a", "end-a", "start-b", "end-b", "start-c", "something-c", "something-more-c", "end-c"]

, используя String Stream, как верхний массив, пытаясь отделить элемент start-* ~ end-*, как в результате. 

["start-a", "during-a", "end-a"]
["start-b", "end-b"]
["start-c", "something-c", "end-c"]

Я пытаюсь использовать оконный оператор 

    @CheckReturnValue
    @BackpressureSupport(BackpressureKind.ERROR)
    @SchedulerSupport(SchedulerSupport.NONE)
    public final <U, V> Flowable<Flowable<T>> window(
            Publisher<U> openingIndicator,
            Function<? super U, ? extends Publisher<V>> closingIndicator) {
        return window(openingIndicator, closingIndicator, bufferSize());
    }

isЕсть ли пример использования оконного оператора (OpeningIndicator, ClosingIndicator)?

...