We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3e68f0b commit 9a348c6Copy full SHA for 9a348c6
internal/grpcsync/callback_serializer.go
@@ -84,10 +84,7 @@ func (cs *CallbackSerializer) run(ctx context.Context) {
84
case <-ctx.Done():
85
// Do nothing here. Next iteration of the for loop will not happen,
86
// since ctx.Err() would be non-nil.
87
- case callback, ok := <-cs.callbacks.Get():
88
- if !ok {
89
- return
90
- }
+ case callback := <-cs.callbacks.Get():
91
cs.callbacks.Load()
92
callback.(func(ctx context.Context))(ctx)
93
}
0 commit comments