reactive-livedata/src/main/java/it/niedermann/android/reactivelivedata/flatmap/FlatMapLiveData.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

package it.niedermann.android.reactivelivedata.flatmap;

import androidx.annotation.NonNull;
import androidx.core.util.Supplier;
import androidx.lifecycle.LiveData;
import androidx.lifecycle.Transformations;

import it.niedermann.android.reactivelivedata.ReactiveLiveData;
import kotlin.jvm.functions.Function1;

public class FlatMapLiveData<T, Y> extends ReactiveLiveData<Y> {

    public FlatMapLiveData(@NonNull LiveData<T> source, @NonNull Supplier<LiveData<Y>> switchMapSupplier) {
        this(source, val -> switchMapSupplier.get());
    }

    public FlatMapLiveData(@NonNull LiveData<T> source, @NonNull Function1<T, LiveData<Y>> flatMapFunction) {
        super(Transformations.switchMap(source, flatMapFunction));
    }
}