implemented data stream as a queue, to get ready for super congestion