autoStream<T> method

Future autoStream<T>(
  1. LifecycleCallback<Stream<T>> stream, {
  2. bool cancelOnError = false,
})

Implementation

Future autoStream<T>(LifecycleCallback<Stream<T>> stream,
    {bool cancelOnError = false}) async {
  onStartup(() async {
    final subscribe = (await stream()).listen((_) {}, cancelOnError: false);

    onShutdown(() async {
      await subscribe.cancel();
    });
  });
}