next method

@override void next(T value)

Pass a value to the observer.

Implementation

@override
void next(T value) {
  if (bufferSize != null) {
    while (_buffer.length >= bufferSize!) {
      _buffer.removeFirst();
    }
  }
  _buffer.addLast(value);
  super.next(value);
}