no more queue.shift, expanding subscribe cb callbacks