ObservableRxList

ObservableRxList.java

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

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

/**
 * http://stackoverflow.com/questions/28816691/how-can-i-create-an-observer-over-a-dynamic-list-in-rxjava
 */
public class ObservableRxList<T> {

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

    public ObservableRxList() {
        this.list = new ArrayList<T>();
        this.subject = PublishSubject.create();
    }

    public void add(T value) {
        list.add(value);
        subject.onNext(value);
    }

    public void update(T value) {
        for (ListIterator<T> it = list.listIterator(); it.hasNext(); ) {
            if (value.equals(it.next())) {
                it.set(value);
                subject.onNext(value);
                return;
            }
        }
    }

    public void remove(T value) {
        list.remove(value);
        subject.onNext(value);
    }

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

    public Observable<T> getCurrentList() {
        return Observable.from(list);
    }

}

The subject subscriber would not know when the operation was an addition, removal. etc... Or am I missing something?

if (value.equals(it.next())) {

would always fail though. didn't you try to compare references to update here? otherwise try to updateAt instead

Hi, @jam01 is right, I improved your answer and post here