@override Future<void> replyToMessage(String id, String? json) async { _pendingReplies.remove(id)?.complete(json); }