analyzeParallelStream method

Stream<FileAnalysisResult> analyzeParallelStream()

Analyzes files in parallel and streams results.

Combines parallel processing with streaming for optimal throughput and memory efficiency.

Implementation

Stream<FileAnalysisResult> analyzeParallelStream() async* {
  final files = discoverFiles();
  final chunks = _chunkList(files, config.chunkSize);

  for (final chunk in chunks) {
    final results = await _processChunkParallel(chunk);
    for (final result in results) {
      yield result;
    }
  }
}