public Observable call()

in mobius-rx/src/main/java/com/spotify/mobius/rx/FlatMapCompletable.java [85:115]

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

  public Observable<R> call(Observable<T> observable) {
    return observable.flatMap(
        new Func1<T, Observable<R>>() {
          @Override
          public Observable<R> call(final T value) {
            Completable completable = func.call(value);

            if (scheduler != null) {
              completable = completable.subscribeOn(scheduler);
            }

            return completable
                .toObservable()
                .ignoreElements()
                .map(
                    new Func1<Object, R>() {
                      @Override
                      public R call(Object ignored) {
                        // Since our upstream has ignoreElements on it, values will never ever be
                        // emitted, and therefore this function call won't actually be executed.
                        // This map is  really only present in order to cast the stream to type R.
                        // Throwing an exception in this never-to-be-executed function allows us
                        // say that the return type is T without actually needing to be able to
                        // produce values of type T.
                        throw new IllegalStateException(
                            "Impossible state! ignoreElements() mustn't allow values to be emitted!");
                      }
                    });
          }
        });
  }