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