public Observable call()

in mobius-rx/src/main/java/com/spotify/mobius/rx/MobiusEffectRouter.java [51:72]

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

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