close method

@override void close()

Implementation

@override void close() {
  _isClosed = true;
  _send();

  while (_completers.isNotEmpty) {
    final completer = _completers.removeFirst();
    completer.complete(
      _data.isNotEmpty? _data.top()
        : null
    );
  }

  while(_streams.isNotEmpty) {
    final controller = _streams.removeFirst();
    controller.close();
  }
}