@override Future<void> ping({required String topic}) async { try { return await engine.ping(topic: topic); } catch (e) { rethrow; } }