Fix goroutines in chan-throttler* logic
Revert pipe macro, close bucket channel when pipe returns nil