public SubtypeEffectHandlerBuilder withFatalErrorHandler()

in mobius-rx2/src/main/java/com/spotify/mobius/rx2/RxMobius.java [453:473]

• 19 lines of code
• 2 McCabe index (conditional complexity)

    public SubtypeEffectHandlerBuilder<F, E> withFatalErrorHandler(
        final Function<ObservableTransformer<? extends F, E>, Consumer<Throwable>> function) {
      checkNotNull(function);

      this.onErrorFunction =
          new OnErrorFunction<ObservableTransformer<? extends F, E>, Consumer<Throwable>>() {
            @Override
            public Consumer<Throwable> apply(ObservableTransformer<? extends F, E> effectHandler) {
              try {
                return function.apply(effectHandler);
              } catch (Exception e) {
                throw new RuntimeException(
                    "FATAL: fatal error handler threw exception for effect handler: "
                        + effectHandler,
                    e);
              }
            }
          };

      return this;
    }