static <T> Multi<T> |
Multi.empty() |
Get a Multi instance that completes immediately.
|
static <T> Multi<T> |
Multi.error(Throwable error) |
Create a Multi instance that reports the given exception to its subscriber(s).
|
static <T> Multi<T> |
Multi.from(Flow.Publisher<T> source) |
Create a Multi instance wrapped around the given publisher.
|
static <T> Multi<T> |
Multi.just(Collection<T> items) |
Create a Multi instance that publishes the given items to a single subscriber.
|
static <T> Multi<T> |
Multi.just(T... items) |
Create a Multi instance that publishes the given items to a single subscriber.
|
default <U> Multi<U> |
Multi.map(Mapper<T,U> mapper) |
|
default <U> Multi<U> |
Single.mapMany(Mapper<T,Flow.Publisher<U>> mapper) |
Map this Single instance to a publisher using the given Mapper .
|
static <T> Multi<T> |
Multi.never() |
Get a Multi instance that never completes.
|