so I have a list of requests, which I want to uplo...

# rx

[ursus]

so I have a list of requests, which I want to upload, however only 5 parallel are allowed, so I have a new scheduler for that, it works, however what the issue is that Observable.fromIterable(it) splits it to per item, but, subscriptions to upload seem to be race-y, and not in the order of the list

[Paul Woitaschek]

Like this?

fun doStuff(listOfRequests: Observable<List<Request>>) {
    listOfRequests.flatMap { requests ->
      val uploads = requests.map { upload(it).toObservable<Nothing>() }
      Observable.concatEager(uploads, 5, 0)
    }
  }

[ursus]

Is that different from listsOfRequests.concatMapEager ?

[ursus]

if not then, subscribes are race-y, just outputs are ordered