NSQ reader that takes an unordered out-of-time stream and turns it into an ordered in-time stream + lag