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