Deliver the first item immediately, ‘debounce’ following items

by

Update:
From @lopar’s comments a better way would be:

Observable.from(items).publish(publishedItems -> publishedItems.limit(1).concatWith(publishedItems.skip(1).debounce(1, TimeUnit.SECONDS)))

Would something like this work:

String[] items = {"one", "two", "three", "four", "five"};
Observable<String> myObservable = Observable.from(items);
Observable.concat(
  myObservable.first(), 
  myObservable.skip(1).debounce(1, TimeUnit.SECONDS)
).subscribe(s -> 
  System.out.println(s));

More Related Contents:

  1. Use cases for RxJava schedulers
  2. Get response status code using Retrofit 2.0 and RxJava
  3. Combine a list of Observables and wait until all completed
  4. How can I create an Observer over a dynamic list in RxJava?
  5. Do small Calculation Task in Background Using RxJava in Most Efficient Way
  6. When do you use map vs flatMap in RxJava?
  7. Rxjava Android how to use the Zip operator
  8. Kotlin: Whats does “return@” mean?
  9. rxjava: Can I use retry() but with delay?
  10. RxJava instead of AsyncTask?
  11. RxJava delay for each item of list emitted
  12. When should one use RxJava Observable and when simple Callback on Android?
  13. What is the difference between flatmap and switchmap in RxJava?
  14. Chaining requests in Retrofit + RxJava
  15. Retrofit and RxJava: How to combine two requests and get access to both results?
  16. What is the difference between concatMap and flatMap in RxJava
  17. Single Observable with Multiple Subscribers
  18. Paginate Observable results without recursion – RxJava
  19. Android RxJava 2 JUnit test – getMainLooper in android.os.Looper not mocked RuntimeException
  20. RxJava Fetching Observables In Parallel
  21. Handle Paging with RxJava
  22. retrofit with rxjava handling network exceptions globally
  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