Future<void> deleteSubscriptionMessages(String topic) async { messageRecords.remove(topic); await persist(); }