begin implementing a queue system for stream progress