mobius-rx2/src/main/java/com/spotify/mobius/rx2/Transformers.java [180:203]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                            return function.apply(f);
                          }
                        });
                return scheduler == null ? eventObservable : eventObservable.subscribeOn(scheduler);
              }
            });
      }
    };
  }

  /**
   * Creates an {@link ObservableTransformer} that will flatten the provided {@link Function} into
   * the stream as an {@link Observable} every time it receives an effect from the upstream effects
   * observable. This will result in calling the function on the immediate scheduler, and passing it
   * the requested effect object then emitting its returned value.
   *
   * @param function {@link Function} to be invoked every time the effect is requested
   * @param <F> the type of Effect this transformer handles
   * @param <E> the type of Event this transformer emits
   * @return an {@link ObservableTransformer} that can be used with a {@link
   *     SubtypeEffectHandlerBuilder}.
   */
  static <F, E> ObservableTransformer<F, E> fromFunction(final Function<F, E> function) {
    return fromFunction(function, null);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



mobius-rx3/src/main/java/com/spotify/mobius/rx3/Transformers.java [176:199]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                            return function.apply(f);
                          }
                        });
                return scheduler == null ? eventObservable : eventObservable.subscribeOn(scheduler);
              }
            });
      }
    };
  }

  /**
   * Creates an {@link ObservableTransformer} that will flatten the provided {@link Function} into
   * the stream as an {@link Observable} every time it receives an effect from the upstream effects
   * observable. This will result in calling the function on the immediate scheduler, and passing it
   * the requested effect object then emitting its returned value.
   *
   * @param function {@link Function} to be invoked every time the effect is requested
   * @param <F> the type of Effect this transformer handles
   * @param <E> the type of Event this transformer emits
   * @return an {@link ObservableTransformer} that can be used with a {@link
   *     RxMobius.SubtypeEffectHandlerBuilder}.
   */
  static <F, E> ObservableTransformer<F, E> fromFunction(final Function<F, E> function) {
    return fromFunction(function, null);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -