如何在 RxJava 中的动态列表上创建观察者？

我需要在不断变化的数组上创建一个观察者（添加元素）。

我正在使用 Observable.from(Iterable) 但它似乎在 ArrayList 上创建了 Observable，就像创建时一样。

我需要通知观察者并在每次 ArrayList 添加新元素时执行操作。

就这样吧。感谢 RxJava Google Group 上的 Dávid Karnok

import java.util.ArrayList;
import java.util.List;

import rx.Observable;
import rx.subjects.PublishSubject;

public class ObservableListExample {

    public static class ObservableList<T> {

        protected final List<T> list;
        protected final PublishSubject<T> onAdd;

        public ObservableList() {
            this.list = new ArrayList<T>();
            this.onAdd = PublishSubject.create();
        }
        public void add(T value) {
            list.add(value);
            onAdd.onNext(value);
        }
        public Observable<T> getObservable() {
            return onAdd;
        }
    }

    public static void main(String[] args) throws Exception {
        ObservableList<Integer> olist = new ObservableList<>();

        olist.getObservable().subscribe(System.out::println);

        olist.add(1);
        Thread.sleep(1000);
        olist.add(2);
        Thread.sleep(1000);
        olist.add(3);
    }
}