more safety in DeStreamer + sockio now emitting whole txn queues