ObservableMergers.java 文件源码

@SafeVarargs
public static <T> void mergeList(ObservableList<T> into, ObservableList<T>... lists) {
    final ObservableList<T> list = into;
    for (ObservableList<T> l : lists) {
        list.addAll(l);
        l.addListener((ListChangeListener<T>) c -> {
            while (c.next()) {
                if (c.wasAdded()) {
                    list.addAll(c.getAddedSubList());
                }
                if (c.wasRemoved()) {
                    list.removeAll(c.getRemoved());
                }
            }
        });
    }
}