class FilesToPrompt::ConcurrentFileFinder

Overview

Concurrent file discovery using fibers and channels

Defined in:

concurrent_file_finder.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(worker_count : Int32 = 4) #

[View source]

Instance Method Detail

def completion_channel : Channel(Array(String)) #

[View source]
def completion_channel=(completion_channel : Channel(Array(String))) #

[View source]
def find_files_concurrently(start_paths : Array(String), config : ProcessingConfig, app : App) : Array(String) #

Find files concurrently using the worker pool


[View source]
def job_channel : Channel(DirJob) #

[View source]
def job_channel=(job_channel : Channel(DirJob)) #

[View source]
def result_channel : Channel(FileResult) #

[View source]
def result_channel=(result_channel : Channel(FileResult)) #

[View source]
def worker_completion_channel : Channel(Nil) #

[View source]
def worker_completion_channel=(worker_completion_channel : Channel(Nil)) #

[View source]
def worker_count : Int32 #

[View source]
def worker_count=(worker_count : Int32) #

[View source]