closeInstance method
void
closeInstance()
Should be called whenever the instance of this Fkafka object is not going to be used anymore.
Implementation
void closeInstance() {
for (final subscribers in _subscribers.values) {
for (final subscriber in subscribers) {
subscriber.subscription.cancel();
}
}
_subscribers.clear();
}