src/main/java/io/reactivex/plugins/RxJavaPlugins.java
@SuppressWarnings("rawtypes")
    public static void setOnConnectableFlowableAssembly(@Nullable Function<? super ConnectableFlowable, ? extends ConnectableFlowable> onConnectableFlowableAssembly) {
        if (lockdown) {
            throw new IllegalStateException("Plugins can't be changed anymore");
        }
        RxJavaPlugins.onConnectableFlowableAssembly = onConnectableFlowableAssembly;
    }
@SuppressWarnings("rawtypes")
    public static void setOnConnectableFlowableAssembly(@Nullable Function<? super ConnectableFlowable, ? extends ConnectableFlowable> onConnectableFlowableAssembly) {
        if (lockdown) {
            throw new IllegalStateException("Plugins can't be changed anymore");
        }
        RxJavaPlugins.onConnectableFlowableAssembly = onConnectableFlowableAssembly;
    }
@ SuppressWarnings ( "rawtypes" ) public static void setOnConnectableFlowableAssembly ( @ Nullable Function < ? super ConnectableFlowable , ? extends ConnectableFlowable > onConnectableFlowableAssembly ) { if ( lockdown ) { throw new IllegalStateException ( "Plugins can't be changed anymore" ) ; } RxJavaPlugins . onConnectableFlowableAssembly = onConnectableFlowableAssembly ; }
Sets the specific hook function.
@param onConnectableFlowableAssembly the hook function to set, null allowed
Sets the specific hook function .