dispose method

  1. @mustCallSuper
  2. @override
void dispose()
override

Implementation

@mustCallSuper
@override
void dispose() {
  _progressStreamSubscription?.cancel();
  _resultStreamSubscription?.cancel();
  _internalProgressEventStream.close();
  _internalResultEventStream.close();
  for (var element in taskStreamMap.values) {
    element.close();
  }
  _progressEventStream = null;
  _resultEventStream = null;
  _progressStreamSubscription = null;
  _resultStreamSubscription = null;
  initCompletable = Completer<bool>();
  _isInitialized = false;
}