Multi onComplete* operators

[danielkec]

Effectively append to the stream with onCompleteResume

• Multi.onCompleteResume

        List<Integer> result = Multi.just(1, 2, 3)
                .onCompleteResume(4)
                .onCompleteResume(5)
                .collectList()
                .await();

        assertThat(result, is(equalTo(List.of(1, 2, 3, 4, 5))));

• Multi.onCompleteResumeWith

        List<Integer> result = Multi.just(1, 2, 3)
                .onCompleteResumeWith(Multi.just(4, 5, 6))
                .collectList()
                .await();

        assertThat(result, is(equalTo(List.of(1, 2, 3, 4, 5, 6))));

Methods common for Multi and Single are accessible at common ancestor Subscribable

        Subscribable<Integer> subs = Single.just(1);

        subs = subs.onCompleteResume(2);

        List<Integer> result = Multi.from(subs)
                .collectList()
                .await();

        assertThat(result, is(equalTo(List.of(1, 2))));

Concat has varargs

assertThat(Multi
                        .concat(Multi.from(TEST_DATA_1),
                                Multi.just(TEST_DATA_2),
                                Multi.just(TEST_DATA_3),
                                Multi.just(TEST_DATA_4),
                                Multi.just(TEST_DATA_5),
                                Multi.just(TEST_DATA_6)
                        )
                        .collectList()
                        .await(),
                is(equalTo(flatMap.apply(List.of(
                        TEST_DATA_1,
                        TEST_DATA_2,
                        TEST_DATA_3,
                        TEST_DATA_4,
                        TEST_DATA_5,
                        TEST_DATA_6
                )))));

Signed-off-by: Daniel Kec daniel.kec@oracle.com

[tomas-langer]

LGTM