Skip to content

Commit

Permalink
Fix send to closed channel.
Browse files Browse the repository at this point in the history
Signed-off-by: Aleskey Sin <leks.sin@gmail.com>
  • Loading branch information
IKSIN committed Feb 3, 2020
1 parent b5313d5 commit f62669f
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/store/proxy.go
Original file line number Diff line number Diff line change
Expand Up @@ -403,6 +403,7 @@ func startStreamSeriesSet(
go func() {
r, err := s.stream.Recv()
rCh <- &recvResponse{r: r, err: err}
close(rCh)
}()

select {
Expand All @@ -414,7 +415,6 @@ func startStreamSeriesSet(
return
case rr = <-rCh:
}
close(rCh)

if rr.err == io.EOF {
return
Expand Down

0 comments on commit f62669f

Please sign in to comment.