autoSubscribe method

Future autoSubscribe(
  1. String name,
  2. LifecycleCallback<StreamSubscription> generate
)

Implementation

Future autoSubscribe(
    String name, LifecycleCallback<StreamSubscription> generate) async {
  onStartup(() async {
    final subscribe = await generate();

    onDestroy(name, () async {
      await subscribe.cancel();
    });
  });
}