disconnect method

  1. @override
Future<void> disconnect({
  1. required String topic,
  2. ErrorResponse? reason,
})
override

Implementation

@override
Future<void> disconnect({
  required String topic,
  ErrorResponse? reason,
}) {
  try {
    return engine.disconnect(
      topic: topic,
      reason: reason,
    );
  } catch (error) {
    logger.e(error is ErrorResponse ? error.message : error.toString());
    rethrow;
  }
}