improving streaming and goroutines