Future? cancel()

in lib/src/stream_queue.dart [389:401]

• 11 lines of code
• 4 McCabe index (conditional complexity)

  Future? cancel({bool immediate = false}) {
    _checkNotClosed();
    _isClosed = true;

    if (!immediate) {
      var request = _CancelRequest<T>(this);
      _addRequest(request);
      return request.future;
    }

    if (_isDone && _eventQueue.isEmpty) return Future.value();
    return _cancel();
  }