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 ) ; }
Register the given complete function to be called once this queue entry has been completed .