Skip to content

Commit b03041a

Browse files
committed
Simplify Feed Close
1 parent 3dd2e20 commit b03041a

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

feed.go

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -70,11 +70,7 @@ func (f *Feed[T, M]) Close() error {
7070
f.quitOnce.Do(func() {
7171
close(f.quit)
7272
})
73-
done := make(chan struct{})
74-
go func() {
75-
f.wg.Wait()
76-
close(done)
77-
}()
73+
f.wg.Wait()
7874

7975
f.mu.Lock()
8076
defer f.mu.Unlock()

0 commit comments

Comments
 (0)