MediatorLiveData: LiveData 衍生物源码详解

2023-10-01 18:04:18

MediatorLiveData：LiveData的强大聚合器

在构建健壮且响应迅速的Android应用程序时，管理数据至关重要。Android架构组件（AAC）库提供了一系列工具，帮助我们高效地处理数据，其中之一便是LiveData。本文将深入探讨MediatorLiveData，一种高级LiveData子类，它提供强大的数据聚合功能。

什么是MediatorLiveData？

MediatorLiveData是LiveData的一个扩展，它允许我们将多个LiveData对象作为数据源进行监听。它充当数据聚合器，当任何数据源发生变化时，它都会更新自己的值。这使得我们在需要将数据从不同来源组合到一个单一的可观察对象中时，可以实现数据的集中式管理。

MediatorLiveData的设计

MediatorLiveData的源码相当简洁，只有不到100行代码。它遵循观察者模式，其中MediatorLiveData是观察者，而它监听的LiveData对象是可观察者。MediatorLiveData内部维护了一个观察者列表，当它监听的LiveData对象中的任何一个发生变化时，它会通知自己的观察者。

使用MediatorLiveData

MediatorLiveData有两种主要用法：

作为数据源的聚合器： 我们可以将多个LiveData对象作为MediatorLiveData的数据源，然后监听MediatorLiveData的值的变化。当任何数据源发生变化时，MediatorLiveData都会更新自己的值。
作为普通的MutableLiveData： MediatorLiveData也可以像普通的MutableLiveData一样使用。我们可以直接设置其值，然后观察其值的变化。

源码分析

下面我们来分析MediatorLiveData的源码：

public class MediatorLiveData<T> extends MutableLiveData<T> {

    private final MediatorLiveData<T>.LiveDataConsumer mSource;

    public MediatorLiveData() {
        mSource = new LiveDataConsumer();
    }

    public <S> void addSource(LiveData<S> source, Observer<S> onChanged) {
        Source<S> s = new Source<>(this, source, onChanged);
        mSource.addSource(s);
        source.observeForever(s);
    }

    @Override
    public void setValue(T value) {
        mSource.setValue(value);
    }

    private static class Source<V> implements Observer<V> {

        private final MediatorLiveData mLiveData;
        private final LiveData<V> mSource;
        private final Observer<V> mObserver;

        Source(MediatorLiveData mLiveData, LiveData<V> mSource, Observer<V> mObserver) {
            this.mLiveData = mLiveData;
            this.mSource = mSource;
            this.mObserver = mObserver;
        }

        @Override
        public void onChanged(V v) {
            mLiveData.mSource.removeSource(this);
            mSource.removeObserver(this);
            mObserver.onChanged(v);
        }
    }

    private static class LiveDataConsumer extends MutableLiveData {

        private boolean mHandlingValue;
        private final List<MediatorLiveData.Source> mSources = new ArrayList<>();

        @Override
        public void setValue(Object value) {
            if (mHandlingValue) {
                return;
            }
            mHandlingValue = true;
            super.setValue(value);
            mHandlingValue = false;
        }

        void addSource(MediatorLiveData.Source source) {
            mSources.add(source);
        }

        void removeSource(MediatorLiveData.Source source) {
            mSources.remove(source);
        }

        @Override
        protected void onActive() {
            for (MediatorLiveData.Source s : mSources) {
                s.mSource.observeForever(s);
            }
        }

        @Override
        protected void onInactive() {
            for (MediatorLiveData.Source s : mSources) {
                s.mSource.removeObserver(s);
            }
        }
    }
}

LiveDataConsumer 类是MediatorLiveData的一个内部类，它充当MediatorLiveData的数据源的聚合器。它维护了一个Source对象列表，这些Source对象代表MediatorLiveData监听的LiveData对象。

Source 类是一个内部类，它充当MediatorLiveData和它监听的LiveData对象之间的桥梁。它实现了Observer接口，当它监听的LiveData对象发生变化时，它会将变化通知给MediatorLiveData。

结论

MediatorLiveData是一个强大的工具，它允许我们在Android应用程序中聚合来自不同来源的数据。它的源码相对简洁，易于理解。通过深入分析其源码，我们可以更好地理解MediatorLiveData的工作原理，并将其应用于我们的项目中。

常见问题解答

如何使用MediatorLiveData聚合多个LiveData对象？

MediatorLiveData<T> mediatorLiveData = new MediatorLiveData<>();
mediatorLiveData.addSource(liveData1, observer1);
mediatorLiveData.addSource(liveData2, observer2);