onFinished method

Stream<T> onFinished(FutureOr<void> callback())

Registers a callback to be invoked once the stream is done

Implementation

Stream<T> onFinished(FutureOr<void> Function() callback) {
  var finished = false;
  FutureOr<void> finishedCallback() {
    if (finished) {
      return null;
    }
    finished = true;
    // ignore: discarded_futures
    return callback();
  }

  return cast<T>().transform(
    DoStreamTransformer<T>(
      onCancel: finishedCallback,
      onDone: finishedCallback,
    ),
  );
}