public Observable call()

in mobius-rx/src/main/java/com/spotify/mobius/rx/Transformers.java [143:159]

17 lines of code
2 McCabe index (conditional complexity)


      public Observable<E> call(Observable<F> effectStream) {
        return effectStream.flatMap(
            new Func1<F, Observable<E>>() {
              @Override
              public Observable<E> call(final F f) {
                Observable<E> eventObservable =
                    Observable.fromCallable(
                        new Callable<E>() {
                          @Override
                          public E call() throws Exception {
                            return function.apply(f);
                          }
                        });
                return scheduler == null ? eventObservable : eventObservable.subscribeOn(scheduler);
              }
            });
      }