watch<T extends Object> method

Stream<T>? watch<T extends Object>({
  1. String? mark,
})

Subscribing to a shared listener data object.

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

Implementation

Stream<T>? watch<T extends Object>({
  String? mark,
}) {
  final String key = keyGet<T>(mark);
  final Iterable keys = _recordListenPool.keys;
  if (keys.contains(key)) {
    final StreamController<T>? gstreamController = instanceListenGet<T>(_recordListenPool, key);
    return gstreamController?.stream;
  }
  return null;
}