close method

  1. @override
void close()
override

Closes the channel so that no more values can be sent to it.

Implementation

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

  while (_completers.isNotEmpty) {
    final Completer<ChannelEvent<T>> completer = _completers.removeFirst();
    completer.complete(ChannelEvent<T>(null, true));
  }
}