rxのライブカウントされた要素

Question

RxAndroidのストリームですでに処理されている要素の数を数える方法はありますか？

私はそのような何か持っています：

Observable.fromArray(new String[]{"these", "are", "my", "values", "."}) 
      .map(s -> doSomeCoolStuff(s)) 
      // ... 
      .subscribe(amountOfProcessedItems -> Log.d("test", "" + amountOfProcessedItems)); 

をそして、私の出力が既に放出されたアイテムの量をカウントし、基本的には各項目の後、1 2 3 4 5次のようになりますように、私は何かを探しています。

AtomicInteger counter = new AtomicInteger(); 
Observable.fromArray(new String[]{"these", "are", "my", "values", "."}) 
     .map(s -> doSomeCoolStuff(s)) 
     // ... 
     .subscribe(dummy -> Log.d("test", "" + counter.incrementAndGet())); 

編集：

Answer 1

だけの要素を数える私は、具体的に `mapWithIndex`方法があることを理解

sourceOservable 
.zipWith(Observable.range(0, Integer.MAX_VALUE), (any, counter) -> counter) 
.whatever(...)