Add BUG comment about aggregator draining.

This commit is contained in:
Julius Volz 2013-07-19 18:10:40 +02:00
parent 606d120541
commit ca1eb66df4

View File

@ -289,6 +289,7 @@ func (a *Aggregator) Dispatch(s SummaryReceiver) {
case req := <-a.closeRequests: case req := <-a.closeRequests:
a.closeInternal() a.closeInternal()
req.done <- true req.done <- true
// BUG: Simply returning here will prevent proper draining. Fix this.
return return
} }
} }