RootPod<T extends Object>.fromStream constructor

RootPod<T extends Object>.fromStream(
  1. Stream<T> stream, {
  2. required T initialValue,
})

Implementation

RootPod.fromStream(Stream<T> stream, {required T initialValue})
  : value = initialValue {
  final subscription = stream.listen(_set);
  onAfterDispose = () {
    unawaited(subscription.cancel());
  };
}