in mobius-rx/src/main/java/com/spotify/mobius/rx/FlatMapCompletable.java [53:69]
static <T, R> FlatMapCompletable<T, R> createForAction(
final Action1<T> action, @Nullable Scheduler scheduler) {
return create(
new Func1<T, Completable>() {
@Override
public Completable call(final T t) {
return Completable.fromAction(
new Action0() {
@Override
public void call() {
action.call(t);
}
});
}
},
scheduler);
}