Advertisement
Guest User

Untitled

a guest
Nov 12th, 2019
107
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.76 KB | None | 0 0
  1. private val uploadSchedules = Schedulers.from(Executors.newFixedThreadPool(5))
  2.  
  3. fun upload(request: Request) : Completable {
  4. Observable.just(request)
  5. .flatMap { request -> upload(request).subscribeOn(uploadScheduler) }
  6. }
  7.  
  8. fun upload(requests: List<Request>) : Completable {
  9. Observable.fromIterable(requests)
  10. // here the subscriptions order are race-y, I want to want them ordered by the order of the list--|
  11. .flatMap { request -> upload(request) |
  12. .subscribeOn(uploadScheduler) |
  13. .doOnSubscribe { log(request) } <-------------------------------------------------|
  14. }
  15. }
  16.  
  17. // log outputs:
  18. // request 0
  19. // request 3
  20. // request 4
  21. // request 2
  22. // request 1
  23. // etc, race-y, random order
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement