void (CFGBuilder builder, PsiExpression qualifier) { builder .dup() .unwrap(SpecialField.CONSUMED_STREAM) .ensure(RelationType.NE, DfStreamStateType.CONSUMED, new ConsumedStreamProblem(qualifier), "java.lang.IllegalStateException") .push(DfStreamStateType.CONSUMED) .assign() .pop(); }