refactor: close buffer done

woorui · Jun 1, 2023 · 408eaef · 408eaef
1 parent 0f800a4
commit 408eaef
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/buffer.go b/buffer.go
@@ -184,7 +184,7 @@ func (b *Buffer[T]) run() {
 		case <-b.ctx.Done():
 			close(b.datas)
 			b.internalFlush(flat)
-			b.done <- struct{}{}
+			close(b.done)
 			return
 		case d := <-b.datas:
 			flat = append(flat, d)