streamOf<T> method

Stream<T> streamOf<T>({
  1. Object? key,
})
override

Implementation

Stream<T> streamOf<T>({Object? key}) {
  try {
    return _injector.get<Stream<T>>(key: _objetcToKey(key));
  } on InjectorException {
    _injector.map<Stream<T>>((i) => _behaviorSubjectOf<T>(key: key).stream,
        isSingleton: true, key: _objetcToKey(key));
    return streamOf<T>(key: key);
  }
}