void (ProblemsHolder holder, DataFlowInstructionVisitor visitor) { visitor.streamConsumed().forKeyValue((psiElement, alwaysFails) -> { if (!REPORT_UNSOUND_WARNINGS && !alwaysFails) return; holder.registerProblem(psiElement, JavaAnalysisBundle.message(alwaysFails ? "dataflow.message.stream.consumed.always" : "dataflow.message.stream.consumed")); }); }