public Observable apply()

in mobius-rx2/src/main/java/com/spotify/mobius/rx2/MergedTransformer.java [46:58]

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

  public Observable<R> apply(Observable<T> input) {
    return input.publish(
        new Function<Observable<T>, Observable<R>>() {
          @Override
          public Observable<R> apply(Observable<T> innerInput) {
            final List<Observable<R>> transformed = new ArrayList<>();
            for (ObservableTransformer<T, R> transformer : transformers) {
              transformed.add(innerInput.compose(transformer));
            }
            return Observable.merge(transformed);
          }
        });
  }