Package io.smallrye.reactive.messaging.providers.helpers

Class MultiUtils

java.lang.Object

io.smallrye.reactive.messaging.providers.helpers.MultiUtils

public class MultiUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
MultiUtils()

Method Summary

Modifier and Type	Method	Description
static <T> io.smallrye.mutiny.Multi<T>	createFromGenerator(Supplier<T> supplier)
static io.smallrye.mutiny.Multi<? extends Message<?>>	handlePreProcessingAcknowledgement(io.smallrye.mutiny.Multi<? extends Message<?>> multi, MediatorConfiguration configuration)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MultiUtils

public MultiUtils()

Method Detail

createFromGenerator

public static <T> io.smallrye.mutiny.Multi<T> createFromGenerator(Supplier<T> supplier)

handlePreProcessingAcknowledgement

public static io.smallrye.mutiny.Multi<? extends Message<?>> handlePreProcessingAcknowledgement(io.smallrye.mutiny.Multi<? extends Message<?>> multi,
                                                                                                MediatorConfiguration configuration)