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