ParallelStreamReader reader = null;
try {
reader = new ParallelStreamReader(
reporter, streams,
limit, 4, 2, limit);
reader.start();
int readNum = 0;
while (readNum < limit) {
ReadResult result = reader.getReadResult();
for (IOException ex : result.ioExceptions) {
if (ex != null) {