pauseListeningTo method

void pauseListeningTo({
  1. required String topic,
})

Pause all the subscriptions from this instance of Fkafka to the topic.

Implementation

void pauseListeningTo({
  required String topic,
}) {
  _controllers.putIfAbsent(
    topic,
    () => StreamController.broadcast(),
  );

  final subscribers = _subscribers[topic] ?? <FkafkaSubscriber>[];

  for (var i = 0; i < subscribers.length; i++) {
    final subscriber = subscribers[i];
    subscriber.subscription.cancel();

    subscribers[i] = subscriber.copyWith(
      isActive: false,
    );
  }
}