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