registerListen<T extends Object> method

void registerListen<T extends Object>({ String? mark, bool broadcast = false, bool sync = false, })

Register a global shared listener object.

mark -- Is the unique identifier of the shared data object before the query.

broadcast -- Listener broadcast form of shared object.

sync -- Whether the broadcast event should be delayed.

Implementation

void registerListen<T extends Object>({
  String? mark,
  bool broadcast = false,
  bool sync = false,
}) {
  final String key = keyGet<T>(mark);
  final StreamController<T> streamController = broadcast ? StreamController<T>.broadcast(sync: sync) : StreamController<T>(sync: sync);
  _recordListenPool[key] = streamController;
}