@SuppressWarnings({ "rawtypes", "unchecked" })
    @NonNull
    public static <T> Observer<? super T> onSubscribe(@NonNull Observable<T> source, @NonNull Observer<? super T> observer) {
        BiFunction<? super Observable, ? super Observer, ? extends Observer> f = onObservableSubscribe;
        if (f != null) {
            return apply(f, source, observer);
        }
        return observer;
    }
@SuppressWarnings({ "rawtypes", "unchecked" })
    @NonNull
    public static <T> Observer<? super T> onSubscribe(@NonNull Observable<T> source, @NonNull Observer<? super T> observer) {
        BiFunction<? super Observable, ? super Observer, ? extends Observer> f = onObservableSubscribe;
        if (f != null) {
            return apply(f, source, observer);
        }
        return observer;
    }
@ SuppressWarnings ( { "rawtypes" , "unchecked" } ) @ NonNull public static < T > Observer < ? super T > onSubscribe ( @ NonNull Observable < T > source , @ NonNull Observer < ? super T > observer ) { BiFunction < ? super Observable , ? super Observer , ? extends Observer > f = onObservableSubscribe ; if ( f != null ) { return apply ( f , source , observer ) ; } return observer ; }
Calls the associated hook function.
@param <T> the value type
@param source the hook's input value
@param observer the observer
@return the value returned by the hook
Calls the associated hook function .