Skip to content

Commit

Permalink
fix: blocked error channel (#177)
Browse files Browse the repository at this point in the history
  • Loading branch information
hunjixin authored Jun 21, 2024
1 parent b3201ab commit 34182bb
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion pkg/mediator/controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down
2 changes: 1 addition & 1 deletion pkg/resourceprovider/controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 34182bb

Please sign in to comment.