code: public static <T> FlowableTransformer<T,T> doOnNextCountFx(Consumer<Integer> onNext) {
          return obs -> obs.compose(doOnNextCount(i -> runOnFx(i,onNext)));
      }
docs: Performs an action on FX thread on onNext with the provided emission count
  @param onNext
  @param <T>