diff --git a/pkg/com/com.go b/pkg/com/com.go index 5427f963f..229396409 100644 --- a/pkg/com/com.go +++ b/pkg/com/com.go @@ -2,6 +2,7 @@ package com import ( "context" + "github.com/pkg/errors" "golang.org/x/sync/errgroup" ) @@ -64,6 +65,8 @@ func CopyFirst[T any]( } if !ok { + err = errors.New("can't copy from closed channel") + return }