public Observable apply()

in mobius-rx2/src/main/java/com/spotify/mobius/rx2/MobiusEffectRouter.java [52:73]

• 22 lines of code
• 3 McCabe index (conditional complexity)

          public Observable<E> apply(Observable<F> effects) {
            return effects
                .filter(
                    new Predicate<F>() {
                      @Override
                      public boolean test(F e) {
                        for (Class<?> effectClass : effectClasses) {
                          if (effectClass.isAssignableFrom(e.getClass())) {
                            return false;
                          }
                        }
                        return true;
                      }
                    })
                .map(
                    new Function<F, E>() {
                      @Override
                      public E apply(F e) {
                        throw new UnknownEffectException(e);
                      }
                    });
          }