next method

  1. @override
void next(
  1. T value
)
override

Pass a value to the observer.

Implementation

@override
void next(T value) {
  DisposedError.checkNotDisposed(this);
  if (_hasStopped) return;
  for (final observer in [..._observers]) {
    observer.next(value);
  }
}