static ObservableTransformer fromFunction()

in mobius-rx2/src/main/java/com/spotify/mobius/rx2/Transformers.java [166:188]

23 lines of code
2 McCabe index (conditional complexity)


  static <F, E> ObservableTransformer<F, E> fromFunction(
      final Function<F, E> function, @Nullable final Scheduler scheduler) {
    return new ObservableTransformer<F, E>() {
      @Override
      public ObservableSource<E> apply(Observable<F> effectStream) {
        return effectStream.flatMap(
            new Function<F, ObservableSource<E>>() {
              @Override
              public ObservableSource<E> apply(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);
              }
            });
      }
    };
  }