Dselans/graceful-exit

[dselans]

1. Remove looper to avoid races where Consume is ran in multiple goroutines. Full fix (without removing looper) would mean to create a map of loopers per Consume() but that's a decent chunk of work.
2. Update Stop() to wait for Consume()'s to exit (using a waitgroup) + optional timeout