@Test public void testThatStateSupplierCannotBeNullWithEmitterWithSharedState() { assertThrows(IllegalArgumentException.class, () -> Multi.createBy().repeating().uni(null, (x, emitter) -> { })); }
public <S, T> UniRepeat<T> uni(Supplier<S> stateSupplier, Function<S, Uni<? extends T>> producer) { Uni<T> upstream = Uni.createFrom().deferred(stateSupplier, producer); return new UniRepeat<>(upstream); }
MultiRepetition { public <S, T> UniRepeat<T> uni(Supplier<S> stateSupplier, Function<S, Uni<? extends T>> producer) { Uni<T> upstream = Uni.createFrom().deferred(stateSupplier, producer); return new UniRepeat<>(upstream); } }
MultiRepetition { public <S, T> UniRepeat<T> uni(Supplier<S> stateSupplier, Function<S, Uni<? extends T>> producer) { Uni<T> upstream = Uni.createFrom().deferred(stateSupplier, producer); return new UniRepeat<>(upstream); }  }
MultiRepetition { public <S, T> UniRepeat<T> uni(Supplier<S> stateSupplier, Function<S, Uni<? extends T>> producer) { Uni<T> upstream = Uni.createFrom().deferred(stateSupplier, producer); return new UniRepeat<>(upstream); }  UniRepeat<T> uni(Supplier<S> stateSupplier, Function<S, Uni<? extends T>> producer); UniRepeat<T> uni(Supplier<Uni<? extends T>> uniSupplier); UniRepeat<T> completionStage(Supplier<S> stateSupplier,
            Function<S, ? extends CompletionStage<? extends T>> producer); UniRepeat<T> completionStage(Supplier<? extends CompletionStage<? extends T>> supplier); UniRepeat<T> uni(Supplier<S> stateSupplier,
            BiConsumer<S, UniEmitter<? super T>> consumer); UniRepeat<T> uni(Consumer<UniEmitter<? super T>> consumer); UniRepeat<T> supplier(Supplier<? extends T> supplier); UniRepeat<T> supplier(Supplier<S> stateSupplier, Function<S, ? extends T> producer); }
MultiRepetition { public <S, T> UniRepeat<T> uni(Supplier<S> stateSupplier, Function<S, Uni<? extends T>> producer) { Uni<T> upstream = Uni.createFrom().deferred(stateSupplier, producer); return new UniRepeat<>(upstream); }  UniRepeat<T> uni(Supplier<S> stateSupplier, Function<S, Uni<? extends T>> producer); UniRepeat<T> uni(Supplier<Uni<? extends T>> uniSupplier); UniRepeat<T> completionStage(Supplier<S> stateSupplier,
            Function<S, ? extends CompletionStage<? extends T>> producer); UniRepeat<T> completionStage(Supplier<? extends CompletionStage<? extends T>> supplier); UniRepeat<T> uni(Supplier<S> stateSupplier,
            BiConsumer<S, UniEmitter<? super T>> consumer); UniRepeat<T> uni(Consumer<UniEmitter<? super T>> consumer); UniRepeat<T> supplier(Supplier<? extends T> supplier); UniRepeat<T> supplier(Supplier<S> stateSupplier, Function<S, ? extends T> producer);  }