gistfile1.txt

    @Test
    public void testFromGlobalWithDuplicates() throws Exception {
        String str =
                "import java.util.concurrent.atomic.AtomicInteger;\n" +
                "import " + NamedPerson.class.getCanonicalName() + ";\n" +
                "global java.util.List list         \n" +
                "rule R when                        \n" +
                "  $i : AtomicInteger()\n" +
                "  $o : NamedPerson(age > $i.get()) from list\n" +
                "then                               \n" +
                "  insert($o);                      \n" +
                "end                                ";

        KieSession ksession = getKieSession(str);

        List<NamedPerson> strings = Arrays.asList(new NamedPerson("Mario", 1), new NamedPerson("Mario", 2));

        ksession.setGlobal("list", strings);

        AtomicInteger i = new AtomicInteger(0);
        FactHandle fh = ksession.insert(i);

        assertThat(ksession.fireAllRules()).isEqualTo(2);

        i.incrementAndGet();
        ksession.update(fh, i);

        assertThat(ksession.fireAllRules()).isEqualTo(1);
    }

    public static class NamedPerson {
        private final String name;
        private final int age;

        public NamedPerson(String name, int age) {
            this.name = name;
            this.age = age;
        }

        @Override
        public boolean equals(Object o) {
            if (this == o) return true;
            if (o == null || getClass() != o.getClass()) return false;
            NamedPerson myPerson = (NamedPerson) o;
            return Objects.equals(name, myPerson.name);
        }

        @Override
        public int hashCode() {
            return Objects.hash(name);
        }

        public int getAge() {
            return age;
        }
    }