code: public static <T> ObservableTransformer<T,T> doOnSubscribeFx(Consumer<Disposable> subscribe) {
          return obs -> obs.doOnSubscribe((d -> runOnFx(d,subscribe)));
      }
docs: Performs a given Action on the FX thread when subscribed to
  @param subscribe
  @param <T>