종료 버그 수정

2018-07-06 02:02:13 +09:00 · 2018-07-06 02:02:13 +09:00 · 2edeef92e8
parent 3b77aae6f2
commit 2edeef92e8
1 changed files with 1 additions and 1 deletions
--- a/producer/processor.go
+++ b/producer/processor.go
@ -239,7 +239,7 @@ func AggregateProcessorChannel(
 	)

 	go func() {
-		<-aggHandler.Done()
+		<-mainHandler.Done()
 		aggHandler.GracefulWait()
 		close(tin)
 		close(fin)