emit<T> method

void emit<T>(
  1. String topic,
  2. T data
)

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,
    ),
  );
}