java - 识别当前正在处理的元素

Question

我想知道如何识别当前正在处理数组中的哪个元素。例如我想打印以下内容:

e
1
Element1 consumed
e
2
Element2 consumed
e
3
Element2 consumed

请问如何修改下面的代码才能达到给定的结果。

代码:

public static void main(String[] args) {
    Observable<String> stringObservable = Observable.just("e1", "e2", "e3");
    stringObservable
    .map(x->x.split(""))//return non-observable
    .flatMap(y->Observable.fromArray(y)//return observable
            .map(n->n))
    .observeOn(Schedulers.io())
    .blockingSubscribe(getObserver());
}

Answer 1

在分割源项目的内部序列上使用 doOnNext 和 doOnComplete:

public static void main(String[] args) {
    Observable<String> stringObservable = Observable.just("e1", "e2", "e3");

    stringObservable
    .flatMap(x ->
        Observable.fromArray(x.split(""))
        .doOnNext(n -> 
            System.out.println(n)) // <-------------------- prints each split item
        .map(n->n)
        .doOnComplete(() -> 
            System.out.println(
               "Element " + x + " consumed")) // <--------- end of processing of x
    )
    .observeOn(Schedulers.io())
    .blockingSubscribe(getObserver());
}