restartDeferred method

void restartDeferred(
  1. Stream<T> factory()
)

Re-executes the stream operation and registers a new factory for future re-activations.

Implementation

void restartDeferred(Stream<T> Function() factory) {
  _cleanup();
  _sourceCompleted = false;
  _assignFactory(factory);
  _setValueInternal(LxWaiting<T>(_value.lastValue));

  // If already active, immediately start bound stream.
  if (hasListener) {
    _checkPendingBind();
  }
}