Skip to content

Commit 847c8f3

Browse files
committed
check done
1 parent f0cd97b commit 847c8f3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

agent/server/snykbroker/supervisor.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -256,7 +256,7 @@ func (b *Supervisor) scanLines(reader io.Reader, output chan string, refCount *s
256256
// increase buffer size from default of 60K to 1MB
257257
buffer := make([]byte, 1024*1024)
258258
go func() {
259-
for {
259+
for !done {
260260
scanner := bufio.NewScanner(reader)
261261
scanner.Buffer(buffer, cap(buffer)-1)
262262
for scanner.Scan() {

0 commit comments

Comments
 (0)