code: public static <T> LatchedObserver<T> createIndexed(Action2<? super T, ? super Integer> onNext) {
          return createIndexed(onNext, new CountDownLatch(1));
      }
docs: Create a LatchedObserver with the given indexed callback function(s).