Changed: running fromCategory().foreachStream() queries in parallel