getEventStream method

@override Stream<EventRecord> getEventStream()

Gets the stream of events for real-time subscriptions.

Returns a broadcast stream that emits EventRecord objects as they occur.

Events are only sent to this stream after calling subscribeToEvents.

Implementation

@override
Stream<EventRecord> getEventStream() {
  _eventStreamController ??= StreamController<EventRecord>.broadcast(
    onListen: () {
      _globalStreamListeners++;
      _ensureListening();
    },
    onCancel: () {
      if (_globalStreamListeners > 0) {
        _globalStreamListeners--;
      }
      _stopListeningIfIdle();
    },
  );
  return _eventStreamController!.stream;
}