Fix #5. Only drain aggregator when it contains data

[aelse]

Fixes a race condition where multiple goroutines evaluate whether aggregator is ready to drain and then attempt to drain it.