Method safeSubscribe

src/main/java/io/reactivex/rxjava3/core/Maybe.java:5089–5093

Wraps the given MaybeObserver, catches any RuntimeExceptions thrown by its MaybeObserver#onSubscribe(Disposable), MaybeObserver#onSuccess(Object), MaybeObserver#onError(Throwable) or MaybeObserver#onComplete() methods and routes those to the global err

(@NonNull MaybeObserver<? super T> observer)

     * @since 3.0.0
     */
    @SchedulerSupport(SchedulerSupport.NONE)
    public final void safeSubscribe(@NonNull MaybeObserver<? super T> observer) {
        Objects.requireNonNull(observer, "observer is null");
        subscribe(new SafeMaybeObserver<>(observer));
    }

    /**
     * Returns a {@link Flowable} which first runs the other {@link CompletableSource}