Fixed infinite stream code to not be bottlenecked by one slow stream.