Package io.helidon.common.reactive

Interface Multi<T>

Type Parameters:

T - item type

All Superinterfaces:

Flow.Publisher<T>, Subscribable<T>

public interface Multi<T>
extends Subscribable<T>

Multiple items publisher facility.

Method Summary

Modifier and Type	Method	Description
default <U> Single<U>	collect(Collector<T,U> collector)	Collect the items of this Multi instance into a Single.
default Single<List<T>>	collectList()	Collect the items of this Multi instance into a Single of List.
static <T> Multi<T>	empty()	Get a Multi instance that completes immediately.
static <T> Multi<T>	error(Throwable error)	Create a Multi instance that reports the given exception to its subscriber(s).
default Single<T>	first()	Get the first item of this Multi instance as a Single.
static <T> Multi<T>	from(Flow.Publisher<T> source)	Create a Multi instance wrapped around the given publisher.
static <T> Multi<T>	just(Collection<T> items)	Create a Multi instance that publishes the given items to a single subscriber.
static <T> Multi<T>	just(T... items)	Create a Multi instance that publishes the given items to a single subscriber.
default <U> Multi<U>	map(Mapper<T,U> mapper)	Map this Multi instance to a new Multi of another type using the given Mapper.
static <T> Multi<T>	never()	Get a Multi instance that never completes.

Methods inherited from interface io.helidon.common.reactive.Flow.Publisher

subscribe

Methods inherited from interface io.helidon.common.reactive.Subscribable

subscribe, subscribe, subscribe, subscribe

Method Detail

map

default <U> Multi<U> map(Mapper<T,U> mapper)

Map this Multi instance to a new Multi of another type using the given Mapper.

Type Parameters:

U - mapped item type

Parameters:

mapper - mapper

Returns:

Multi

Throws:

NullPointerException - if mapper is null

collectList

default Single<List<T>> collectList()

Collect the items of this Multi instance into a Single of List.

Returns:

Single

collect

default <U> Single<U> collect(Collector<T,U> collector)

Collect the items of this Multi instance into a Single.

Type Parameters:

U - collector container type

Parameters:

collector - collector to use

Returns:

Single

Throws:

NullPointerException - if collector is null

first

default Single<T> first()

Get the first item of this Multi instance as a Single.

Returns:

Single

from

static <T> Multi<T> from(Flow.Publisher<T> source)

Create a Multi instance wrapped around the given publisher.

Type Parameters:

T - item type

Parameters:

source - source publisher

Returns:

Multi

Throws:

NullPointerException - if source is null

just

static <T> Multi<T> just(Collection<T> items)

Create a Multi instance that publishes the given items to a single subscriber.

Type Parameters:

T - item type

Parameters:

items - items to publish

Returns:

Multi

Throws:

NullPointerException - if items is null

just

@SafeVarargs
static <T> Multi<T> just(T... items)

Create a Multi instance that publishes the given items to a single subscriber.

Type Parameters:

T - item type

Parameters:

items - items to publish

Returns:

Multi

Throws:

NullPointerException - if items is null

error

static <T> Multi<T> error(Throwable error)

Create a Multi instance that reports the given exception to its subscriber(s). The exception is reported by invoking Flow.Subscriber.onError(java.lang.Throwable) when Flow.Publisher.subscribe(Subscriber) is called.

Type Parameters:

T - item type

Parameters:

error - exception to hold

Returns:

Multi

Throws:

NullPointerException - if error is null

empty

static <T> Multi<T> empty()

Get a Multi instance that completes immediately.

Type Parameters:

T - item type

Returns:

Multi

never

static <T> Multi<T> never()

Get a Multi instance that never completes.

Type Parameters:

T - item type

Returns:

Multi