``` val uploadsScheduler = Schedulers.from(Executo...

# rx

[ursus]

val uploadsScheduler = Schedulers.from(Executors.newFixedThreadPool(5))
val listOfRequests : Observable<List<Request>>

listOfRequests
.flatMap { Observable.fromIterable(it) } // Fan out
.flatMap { 
    upload(request) <-- subscriptions race-y
    	.subscribeOn(uploadsScheduler)
}