@override Future<void> enqueue(String json) async { enqueued.add(json); final peer = _peer; peer?._deliverOrHold(() => peer.emitQueued(json)); }