使用 RxJava 观察列表“添加”和“删除”操作

Question

我想知道是否可以使用 RxJava 来获取 List（更具体地说，是 ArrayList）的更新。 我想要的是让 n 个订阅者在列表添加或删除项目时获得更新。我需要知道操作是什么，而不仅仅是被修改的项目。

我试过搜索这个，但到目前为止我找到的最接近的是这个answer

不过，这里只涉及“添加”功能，不涉及“删除”...

当一个项目被添加到列表时调用一个函数onAdd(Item item)，然后在它被删除时调用另一个函数onRemove(Item item)。

如果这不是使用 RxJava 的正确方法，请告诉我，我正在学习并接受各种帮助/批评 :)

谢谢， 岛

Answer 1

有几种方法可以做到这一点。一种方法是添加第二个 observable，这应该很容易。第二种选择是每次有通知时传递操作。

例如（使用 lombok 生成构造函数、getter 等）：

public class ObservableListExample {

    @NoArgsConstructor
    public static class ObservableList<T> {

        protected final List<T> list = new ArrayList<T>();
        protected final PublishSubject<Notification<T>> onChange = PublishSubject.create();

        public void add(T value) {
            list.add(value);
            onChange.onNext(new Notification<T>(Operation.ADD, value));
        }

        public void remove(T value) {
            list.remove(value);
            onChange.onNext(new Notification<T>(Operation.REMOVE, value));
        }

        public Observable<Notification<T>> getObservable() {
            return onChange;
        }
    }

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

        olist.getObservable().subscribe(n -> System.out.println("op: " + n.getOperation() + " i: " + n.getItem()));

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

    public static enum Operation {
        ADD,
        REMOVE
    }

    @Getter
    @AllArgsConstructor
    public static class Notification<T> {
        private Operation operation;
        private T Item;
    }
}

输出：

op: ADD i: 1
op: ADD i: 2
op: ADD i: 3
op: REMOVE i: 2