subscribe<T> method

  1. @override
StreamSubscription<T> subscribe<T>({
  1. String? path,
  2. String? target,
  3. void onData(
    1. T e
    )?,
  4. Function? onError,
  5. void onDone()?,
  6. bool? cancelOnError,
})
override

Subscribe to events on a specific topic.

Implementation

@override
StreamSubscription<T> subscribe<T>({String? path, String? target,void Function(T e)? onData, Function? onError, void Function()? onDone, bool? cancelOnError}) {
  _checkNotDisposed();
  return _valueStream<T>(Topic.create<T>(path: path, target: target))
      .listen(onData, cancelOnError: cancelOnError, onDone: onDone, onError: onError);
}