public Consumer apply()

in mobius-rx3/src/main/java/com/spotify/mobius/rx3/RxMobius.java [324:333]

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

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