stream property

@override ObservableStream<ResourceState<K, V>> stream

The current state stream.

Implementation

@override
ObservableStream<ResourceState<K, V>> get stream => _stream ??= super
    .stream
    .autorunWhileActive(
      (_) => keyUpdateAutorun(),
      onUpdate: (isRunning) => _isKeyUpdateRunning = isRunning,
    )
    .doOn(
      onData: (_) => _hasStreamValue = true,
      onCancel: () => _hasStreamValue = false,
    )
    .asObservable(name: 'ComputedResourceBloc<$K,$V>.stream');