emit<T> method
Emit an event to all subscribers of topic
.
Implementation
void emit<T>(String topic, T data) {
_controllers.putIfAbsent(
topic,
() => StreamController.broadcast(),
);
_controllers[topic]!.add(
FkafkaEvent<T>(
topic: topic,
data: data,
),
);
}