docs: public void onComplete(
  			final Consumer<StreamElementQueueEntry<T>> completeFunction,
  			Executor executor) {
  		final StreamElementQueueEntry<T> thisReference = this;
  
  		getFuture().whenCompleteAsync(
  			// call the complete function for normal completion as well as exceptional completion
  			// see FLINK-6435
  			(value, throwable) -> completeFunction.accept(thisReference),
  			executor);
  	}