reactive-livedata/src/main/java/it/niedermann/android/reactivelivedata/combinator/DoubleCombinatorLiveData.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.combinator;

import androidx.annotation.NonNull;
import androidx.arch.core.util.Function;
import androidx.core.util.Pair;
import androidx.core.util.Supplier;
import androidx.lifecycle.LiveData;

import it.niedermann.android.reactivelivedata.ReactiveLiveData;

public class DoubleCombinatorLiveData<T, Y> extends ReactiveLiveData<Pair<T, Y>> {

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

    public DoubleCombinatorLiveData(@NonNull LiveData<T> source, @NonNull Function<T, LiveData<Y>> secondSourceFunction) {
        addSource(source, new DoubleCombinatorObserver<>(this, secondSourceFunction));
    }
}