github/steve
1
0
Fork 0
mirror of https://github.com/niusmallnan/steve.git synced 2025-06-22 04:37:07 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #41 from jakefhyde/fix-relationship-closed-channel

Browse Source
This commit is contained in:
Sergey Nasovich 2022-03-03 18:41:26 -05:00 committed by GitHub
commit 283b01b970
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/summarycache/summarycache.go
View File

@ -80,6 +80,7 @@ func (s *SummaryCache) OnInboundRelationshipChange(ctx context.Context, schema *
s.cbs[id] = cb s.cbs[id] = cb
go func() { go func() {
defer close(ret)
for rel := range cb { for rel := range cb {
if rel.Kind == kind && if rel.Kind == kind &&
rel.APIVersion == apiVersion && rel.APIVersion == apiVersion &&
@ -94,7 +95,6 @@ func (s *SummaryCache) OnInboundRelationshipChange(ctx context.Context, schema *
s.Lock() s.Lock()
defer s.Unlock() defer s.Unlock()
close(cb) close(cb)
defer close(ret)
delete(s.cbs, id) delete(s.cbs, id)
}() }()