How can I create an Observer over a dynamic list in RxJava?

by

There you go. Thanks to Dávid Karnok on RxJava Google Group

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);
    }
}

More Related Contents:

  1. Deliver the first item immediately, ‘debounce’ following items
  2. Do small Calculation Task in Background Using RxJava in Most Efficient Way
  3. When do you use map vs flatMap in RxJava?
  4. Rxjava Android how to use the Zip operator
  5. Kotlin: Whats does “return@” mean?
  6. Use cases for RxJava schedulers
  7. rxjava: Can I use retry() but with delay?
  8. RxJava instead of AsyncTask?
  9. RxJava delay for each item of list emitted
  10. When should one use RxJava Observable and when simple Callback on Android?
  11. What is the difference between flatmap and switchmap in RxJava?
  12. Get response status code using Retrofit 2.0 and RxJava
  13. Chaining requests in Retrofit + RxJava
  14. Retrofit and RxJava: How to combine two requests and get access to both results?
  15. What is the difference between concatMap and flatMap in RxJava
  16. Single Observable with Multiple Subscribers
  17. Paginate Observable results without recursion – RxJava
  18. Android RxJava 2 JUnit test – getMainLooper in android.os.Looper not mocked RuntimeException
  19. RxJava Fetching Observables In Parallel
  20. Handle Paging with RxJava
  21. retrofit with rxjava handling network exceptions globally
  22. Combine a list of Observables and wait until all completed
  23. RxJava and parallel execution of observer code
  24. How does backpressure work in Project Reactor?
  25. Do we need to unsubscribe from observable that completes/errors-out?

Leave a Comment