dataChanged method

Stream<List<DataEvent>> dataChanged({
  1. Uri? path,
  2. UriFilterType filterType = UriFilterType.literal,
})

Implementation

Stream<List<DataEvent>> dataChanged(
    {Uri? path, UriFilterType filterType = UriFilterType.literal}) async* {
  await removeDataListener(path: path);
  await channel.invokeMethod(
      "addDataListener",
      path == null
          ? {"name": "global_data_channel"}
          : {"path": path.toString(), "filterType": filterType.index});
  String key = path == null ? "global_data_channel" : path.toString();

  Map<String, StreamController<List<DataEvent>>> _dataStreamControllers =
      _wearOSObserver.streamControllers[ObservableType.data]
          as Map<String, StreamController<List<DataEvent>>>;
  _dataStreamControllers[key] = StreamController.broadcast();
  yield* _dataStreamControllers[key]!.stream;
}