subscribeToComplete method

  1. @override
Disposable subscribeToComplete(
  1. Observer<T> observer
)
override

Implementation

@override
Disposable subscribeToComplete(Observer<T> observer) {
  _buffer.forEach(observer.next);
  return super.subscribeToComplete(observer);
}