RxJava delay for each item of list emitted

by

The simplest way to do this seems to be just using concatMap and wrapping each item in a delayed Obserable. 

long startTime = System.currentTimeMillis();
Observable.range(1, 5)
        .concatMap(i-> Observable.just(i).delay(50, TimeUnit.MILLISECONDS))
        .doOnNext(i-> System.out.println(
                "Item: " + i + ", Time: " + (System.currentTimeMillis() - startTime) +"ms"))
        .toCompletable().await();

Prints: 

Item: 1, Time: 51ms
Item: 2, Time: 101ms
Item: 3, Time: 151ms
Item: 4, Time: 202ms
Item: 5, Time: 252ms

More Related Contents:

  1. How to call a method after a delay in Android
  2. When do you use map vs flatMap in RxJava?
  3. Rxjava Android how to use the Zip operator
  4. How to create a delay in Swing
  5. Use cases for RxJava schedulers
  6. rxjava: Can I use retry() but with delay?
  7. RxJava instead of AsyncTask?
  8. Retrofit and RxJava: How to combine two requests and get access to both results?
  9. What is the difference between concatMap and flatMap in RxJava
  10. Paginate Observable results without recursion – RxJava
  11. RxJava Fetching Observables In Parallel
  12. Combine a list of Observables and wait until all completed
  13. RxJava and parallel execution of observer code
  14. Java Delay/Wait
  15. How can I stack download panes vertically using JavaFX?
  16. What would be the value of variable after executing the following statement
  17. IDEA: javac: source release 1.7 requires target release 1.7
  18. Java Compare Two Lists
  19. Java String replace not working [duplicate]
  20. How to access static resources when mapping a global front controller servlet on /*
  21. Using iTextPDF to trim a page’s whitespace
  22. Registering a headset button click with BroadcastReceiver in Android
  23. What’s a monitor in Java?
  24. How to get the parent base class object super.getClass()
  25. Difference between save and saveAndFlush in Spring data jpa
  26. What does EntityManager.flush do and why do I need to use it?
  27. How to for each the hashmap? [duplicate]
  28. How to connect with Java into Active Directory
  29. How to create GRPC client directly from protobuf without compiling it into java code
  30. HQL joined query to eager fetch a large number of relationships

Leave a Comment