@override Stream<Map<String, dynamic>> subscribeToAllMessages() { _ensureInitializedSync(); return rust_messaging.subscribeToAllMessages().map(_messageInfoToMap); }