cancel method

Future cancel()

Stop listening to the stream for further updates.

Implementation

Future cancel() {
  if (!_done.isCompleted) {
    _done.complete(null);
    return _inputQueue.cancel()!;
  }
  return done;
}