closeConsumer method

void closeConsumer(
  1. String label,
  2. String peerId
)

Implementation

void closeConsumer(String label, String peerId) {
  try {
    Consumer? consumer = getConsumer(label: label, peerId: peerId);
    consumer?.close();
  } catch (error) {
    logger.e('❌ Error closing consumer | error: $error');
  }
}