FkafkaSubscriber<T> constructor

const FkafkaSubscriber<T>({ required bool isActive, required OnTopicCallBack<T> onTopic, required StreamSubscription<FkafkaEvent> subscription, })

Implementation

const FkafkaSubscriber({
  required this.isActive,
  required this.onTopic,
  required this.subscription,
});