code: public static <T> FlowableTransformer<T,T> doOnErrorFx(Consumer<Throwable> onError) {
          return obs -> obs.doOnError(e -> runOnFx(e,onError));
      }
docs: Performs a given action on a Throwable on the FX thread in the event of an onError
  @param onError
  @param <T>