Hi @german.barros,
I can’t say much more on the timeouts you’re seeing with your executor example. My only suggestion is to use flatMap with a maxConcurrent argument instead of using the ExecutorService. That would allow you to create a single timeout for all the work you’re performing.
See this forum post for more on the maxConcurrent approach:
You can also limit in-flight delete requests by limiting the number of subscribers to the flatMap operator performing the deletions. Choose an
Observable.flatMap()method that takes amaxConcurrentparameter.
Jeff