code: public static <T> ObservableTransformer<T,T> doOnNextFx(Consumer<T> onNext) {
          return obs -> obs.doOnNext(t -> runOnFx(t, onNext));
      }
docs: Performs a given action for each item on the FX thread
  @param onNext
  @param <T>