all repos — searchix @ ad69a8fe77bd853143457913b62ce7d6f5bc2946

Search engine for NixOS, nix-darwin, home-manager and NUR users

perf: use buffered channels for importing

Alan Pearce
commit

ad69a8fe77bd853143457913b62ce7d6f5bc2946

parent

0a9814bb65fafcedbefc9cbd153b3ada8141492a

3 files changed, 3 insertions(+), 3 deletions(-)

changed files
M internal/importer/options.go → internal/importer/options.go
@@ -98,7 +98,7 @@ return &i, nil
 }
 
 func (i *OptionIngester) Process(ctx context.Context) (<-chan nix.Importable, <-chan error) {
-	results := make(chan nix.Importable)
+	results := make(chan nix.Importable, 1)
 	errs := make(chan error)
 
 	go func() {
M internal/importer/package.go → internal/importer/package.go
@@ -121,7 +121,7 @@ return l
 }
 
 func (i *PackageIngester) Process(ctx context.Context) (<-chan nix.Importable, <-chan error) {
-	results := make(chan nix.Importable)
+	results := make(chan nix.Importable, 1)
 	errs := make(chan error)
 
 	if i.programs != nil {
M internal/storage/store.go → internal/storage/store.go
@@ -186,7 +186,7 @@ store *Store,
 	source *config.Source,
 ) func(context.Context) (<-chan nix.Importable, <-chan error) {
 	return func(_ context.Context) (<-chan nix.Importable, <-chan error) {
-		results := make(chan nix.Importable)
+		results := make(chan nix.Importable, 1)
 		errs := make(chan error)
 
 		go func() {