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