From 42723a0f4cb7417ac15a4e02440f9b609378264f Mon Sep 17 00:00:00 2001 From: hunjixin <1084400399@qq.com> Date: Fri, 21 Jun 2024 09:59:46 +0800 Subject: [PATCH] fix: blocked error channel --- pkg/mediator/controller.go | 2 +- pkg/resourceprovider/controller.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/mediator/controller.go b/pkg/mediator/controller.go index ddc6e44c..7c201bb1 100644 --- a/pkg/mediator/controller.go +++ b/pkg/mediator/controller.go @@ -124,7 +124,7 @@ func (controller *MediatorController) subscribeToSolver() error { } func (controller *MediatorController) Start(ctx context.Context, cm *system.CleanupManager) chan error { - errorChan := make(chan error) + errorChan := make(chan error, 1) // get the local subscriptions setup err := controller.subscribeToSolver() if err != nil { diff --git a/pkg/resourceprovider/controller.go b/pkg/resourceprovider/controller.go index 456e1a2c..87d8645c 100644 --- a/pkg/resourceprovider/controller.go +++ b/pkg/resourceprovider/controller.go @@ -124,7 +124,7 @@ func (controller *ResourceProviderController) subscribeToWeb3() error { } func (controller *ResourceProviderController) Start(ctx context.Context, cm *system.CleanupManager) chan error { - errorChan := make(chan error) + errorChan := make(chan error, 1) err := controller.subscribeToSolver() if err != nil { errorChan <- err