useStreamSubscription<T> function

StreamSubscription<T> useStreamSubscription<T>(
  1. Stream<T> stream,
  2. void onData(
    1. T event
    )?, {
  3. Function? onError,
  4. void onDone()?,
  5. bool? cancelOnError,
})

Creates a StreamSubscription.

The subscription is automatically cancelled when the widget is unmounted.

Implementation

StreamSubscription<T> useStreamSubscription<T>(
  Stream<T> stream,
  void Function(T event)? onData, {
  Function? onError,
  void Function()? onDone,
  bool? cancelOnError,
}) {
  final sub = stream.listen(
    onData,
    onError: onError,
    onDone: onDone,
    cancelOnError: cancelOnError,
  );
  onBeforeUnmount(sub.cancel);
  return sub;
}