首先是通過adapter來幫助我們實(shí)現(xiàn)好的。

public abstract static class Adapter<VH extends ViewHolder>{
private final AdapterDataObservable mObservable = new AdapterDataObservable();
。。。。
}

mObservable可觀察對象，發(fā)射源

static class AdapterDataObservable extends Observable<AdapterDataObserver> {
        public boolean hasObservers() {
            return !mObservers.isEmpty();
        }

        public void notifyChanged() {
            // since onChanged() is implemented by the app, it could do anything, including
            // removing itself from {@link mObservers} - and that could cause problems if
            // an iterator is used on the ArrayList {@link mObservers}.
            // to avoid such problems, just march thru the list in the reverse order.
            for (int i = mObservers.size() - 1; i >= 0; i--) {
                mObservers.get(i).onChanged();
            }
        }
。。。
}

Observable抽象泛型類，用arraylist存儲觀察者（接收者）；只有注冊和注銷方法

package android.database;

import java.util.ArrayList;
public abstract class Observable<T> {
    /**
     * The list of observers.  An observer can be in the list at most
     * once and will never be null.
     */
    protected final ArrayList<T> mObservers = new ArrayList<T>();

    /**
     * Adds an observer to the list. The observer cannot be null and it must not already
     * be registered.
     * @param observer the observer to register
     * @throws IllegalArgumentException the observer is null
     * @throws IllegalStateException the observer is already registered
     */
    public void registerObserver(T observer) {
        if (observer == null) {
            throw new IllegalArgumentException("The observer is null.");
        }
        synchronized(mObservers) {
            if (mObservers.contains(observer)) {
                throw new IllegalStateException("Observer " + observer + " is already registered.");
            }
            mObservers.add(observer);
        }
    }

    /**
     * Removes a previously registered observer. The observer must not be null and it
     * must already have been registered.
     * @param observer the observer to unregister
     * @throws IllegalArgumentException the observer is null
     * @throws IllegalStateException the observer is not yet registered
     */
    public void unregisterObserver(T observer) {
        if (observer == null) {
            throw new IllegalArgumentException("The observer is null.");
        }
        synchronized(mObservers) {
            int index = mObservers.indexOf(observer);
            if (index == -1) {
                throw new IllegalStateException("Observer " + observer + " was not registered.");
            }
            mObservers.remove(index);
        }
    }

    /**
     * Remove all registered observers.
     */
    public void unregisterAll() {
        synchronized(mObservers) {
            mObservers.clear();
        }
    }
}

public abstract static class AdapterDataObserver定義了觀察者的發(fā)現(xiàn)動作的反應(yīng)
AdapterDataObservable定義了如何觸發(fā)事件

public void registerAdapterDataObserver(@NonNull AdapterDataObserver observer) {
            mObservable.registerObserver(observer);
        }

setAdapterInternal中,recyclerview使用它的adapter注冊了觀察者（此時adapter內(nèi)部的mObservable代表adapter自己，作為發(fā)射源）

if (adapter != null) {
            adapter.registerAdapterDataObserver(mObserver);
            adapter.onAttachedToRecyclerView(this);
        }

觀察者mObserver 是AdapterDataObserver的實(shí)現(xiàn)類實(shí)例，Observable<T>模板中的T

private final RecyclerViewDataObserver mObserver = new RecyclerViewDataObserver();

private class RecyclerViewDataObserver extends AdapterDataObserver{...}

總結(jié)：adapter內(nèi)置的發(fā)射源在setAdapter后，注冊到了接收源，變動等事件就發(fā)射事件通知接受源。
發(fā)送源是有接收源的類型的，這樣才能觸發(fā)相應(yīng)的事件。

image.png