Parallelize reads from the API using Observables.

Use --num-threads to specify the number of read threads per worker.