code: public static <T> FlowableTransformer<T,T> doOnNextCount(Consumer<Integer> onNext) {
          return obs -> obs.lift(new FlowableEmissionCounter<>(new CountObserver(onNext,null,null)));
      }
docs: Performs an action on onNext with the provided emission count
  @param onNext
  @param <T>