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