Initial commit Call flush here Don't set to connected until Activate Undo that Flush for source here too Only queue messages after Snapshot (otherwise ignore) and send when Connected. Add new docs to broadcast By default queuedUntilState is null Remove debug logs Use new ByteStream( data ) instead of create w/ length then write Optimization to remove queues when no longer required (cheers Ziks)