public Stream<Flow> keepLastVersion(Stream<Flow> stream) {
        return keepLastVersionCollector(stream);
    }
@Test
    void sameRevisionWithDeletedUnordered() {
        Stream<Flow> stream = Stream.of(
            create("test", "test", 1),
            create("test", "test2", 2),
            create("test", "test2", 4),
            create("test", "test2", 2).toDeleted()
        );

        List<Flow> collect = flowService.keepLastVersion(stream).toList();

        assertThat(collect.size(), is(1));
        assertThat(collect.getFirst().isDeleted(), is(false));
        assertThat(collect.getFirst().getRevision(), is(4));
    }