dispose method

void dispose()

Closes underlaying stream controller

Implementation

void dispose() {
  if (_isDisposed) {
    throw IllegalStateException(
      message: 'Can\'t call dispose if observable is already disposed.',
    );
  }

  _controller.close();

  _isDisposed = true;
}