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