Class ConcatPublisher<T>

java.lang.Object

io.helidon.common.reactive.ConcatPublisher<T>

Type Parameters:

T - item type

All Implemented Interfaces:

Multi<T>, Subscribable<T>, Flow.Publisher<T>

public final class ConcatPublisher<T>
extends Object
implements Flow.Publisher<T>, Multi<T>

Concat streams to one.

Method Summary

Modifier and Type	Method	Description
static <T> ConcatPublisher<T>	create(Flow.Publisher<T> firstPublisher, Flow.Publisher<T> secondPublisher)	Create new ConcatPublisher.
void	subscribe(Flow.Subscriber<? super T> subscriber)

Methods inherited from class Object

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

Methods inherited from interface Multi

collect, collect, collectList, collectStream, compose, defaultIfEmpty, defaultIfEmpty, distinct, dropWhile, filter, first, flatMap, flatMap, flatMapCompletionStage, flatMapIterable, flatMapIterable, flatMapOptional, forEach, forEachCompletionStage, ifEmpty, ignoreElements, limit, log, log, log, log, map, observeOn, observeOn, onCancel, onComplete, onCompleteResume, onCompleteResumeWith, onError, onErrorResume, onErrorResumeWith, onTerminate, peek, reduce, reduce, retry, retry, retryWhen, skip, switchIfEmpty, takeUntil, takeWhile, timeout, timeout, to

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 <U> Single<U>	collect(Supplier<? extends U> collectionSupplier, BiConsumer<U,T> accumulator)	Collect the items of this Multi into a collection provided via a Supplier and mutated by a BiConsumer callback.
default Single<List<T>>	collectList()	Collect the items of this Multi instance into a Single of List.
default <A,R> Single<R>	collectStream(Collector<T,A,R> collector)	Collects up upstream items with the help of a the callbacks of a Collector.
default <U> Multi<U>	compose(Function<? super Multi<T>, ? extends Flow.Publisher<? extends U>> composer)	Apply the given composer function to the current Multi instance and return aMulti wrapping the returned Flow.Publisher of this function.
default Multi<T>	defaultIfEmpty(Supplier<? extends T> supplier)	Signals the default item supplied by specified supplier if the upstream is empty.
default Multi<T>	defaultIfEmpty(T defaultItem)	Signals the default item if the upstream is empty.
default Multi<T>	distinct()	Filter out all duplicates.
default Multi<T>	dropWhile(Predicate<? super T> predicate)	Drop the longest prefix of elements from this stream that satisfy the given predicate.
default Multi<T>	filter(Predicate<? super T> predicate)	Filter stream items with provided predicate.
default Single<T>	first()	Get the first item of this Multi instance as a Single.
default <U> Multi<U>	flatMap(Function<? super T, ? extends Flow.Publisher<? extends U>> publisherMapper)	Transform item with supplied function and flatten resulting Flow.Publisher to downstream.
default <U> Multi<U>	flatMap(Function<? super T, ? extends Flow.Publisher<? extends U>> mapper, long maxConcurrency, boolean delayErrors, long prefetch)	Transform item with supplied function and flatten resulting Flow.Publisher to downstream while limiting the maximum number of concurrent inner Flow.Publishers and their in-flight item count, optionally aggregating and delaying all errors until all sources terminate.
default <U> Multi<U>	flatMapCompletionStage(Function<? super T, ? extends CompletionStage<? extends U>> mapper)	Transform item with supplied function and flatten resulting CompletionStage results to downstream.
default <U> Multi<U>	flatMapIterable(Function<? super T, ? extends Iterable<? extends U>> iterableMapper)	Transform item with supplied function and flatten resulting Iterable to downstream.
default <U> Multi<U>	flatMapIterable(Function<? super T, ? extends Iterable<? extends U>> iterableMapper, int prefetch)	Transform item with supplied function and flatten resulting Iterable to downstream.
default <U> Multi<U>	flatMapOptional(Function<? super T, Optional<? extends U>> mapper)	Transform item with supplied function and flatten resulting Optional to downstream as one item if present or nothing if empty.
default Single<Void>	forEach(Consumer<? super T> consumer)	Terminal stage, invokes provided consumer for every item in the stream with no backpressure.
default Single<Void>	forEachCompletionStage(Function<? super T, CompletionStage<Void>> function)	Terminal stage, invokes provided consumer for every item in the stream with strict backpressure.
default Multi<T>	ifEmpty(Runnable ifEmpty)	Executes given Runnable when stream is finished without value(empty stream).
default Single<Void>	ignoreElements()	Terminal stage, ignore all items and complete returned Single<Void> successfully or exceptionally.
default Multi<T>	limit(long limit)	Limit stream to allow only specified number of items to pass.
default Multi<T>	log()	Log all signals onSubscribe, onNext, onError, onComplete, cancel and request coming to and from preceding operator.
default Multi<T>	log(Level level)	Log all signals onSubscribe, onNext, onError, onComplete, cancel and request coming to and from preceding operator.
default Multi<T>	log(Level level, boolean trace)	Log all signals onSubscribe, onNext, onError, onComplete, cancel and request coming to and from preceding operator.
default Multi<T>	log(Level level, String loggerName)	Log all signals onSubscribe, onNext, onError, onComplete, cancel and request coming to and from preceding operator.
default <U> Multi<U>	map(Function<? super T, ? extends U> mapper)	Map this Multi instance to a new Multi of another type using the given Function.
default Multi<T>	observeOn(Executor executor)	Re-emit the upstream's signals to the downstream on the given executor's thread using a default buffer size of 32 and errors skipping ahead of items.
default Multi<T>	observeOn(Executor executor, int bufferSize, boolean delayError)	Re-emit the upstream's signals to the downstream on the given executor's thread.
default Multi<T>	onCancel(Runnable onCancel)	Executes given Runnable when a cancel signal is received.
default Multi<T>	onComplete(Runnable onComplete)	Executes given Runnable when onComplete signal is received.
default Multi<T>	onCompleteResume(T item)	Resume stream from single item if onComplete signal is intercepted.
default Multi<T>	onCompleteResumeWith(Flow.Publisher<? extends T> publisher)	Resume stream from supplied publisher if onComplete signal is intercepted.
default Multi<T>	onError(Consumer<? super Throwable> onErrorConsumer)	Executes given Runnable when onError signal is received.
default Multi<T>	onErrorResume(Function<? super Throwable, ? extends T> onError)	Function providing one item to be submitted as onNext in case of onError signal is received.
default Multi<T>	onErrorResumeWith(Function<? super Throwable, ? extends Flow.Publisher<? extends T>> onError)	Resume stream from supplied publisher if onError signal is intercepted.
default Multi<T>	onTerminate(Runnable onTerminate)	Executes given Runnable when any of signals onComplete, onCancel or onError is received.
default Multi<T>	peek(Consumer<? super T> consumer)	Invoke provided consumer for every item in stream.
default Single<T>	reduce(BiFunction<T,T,T> reducer)	Combine subsequent items via a callback function and emit the final value result as a Single.
default <R> Single<R>	reduce(Supplier<? extends R> supplier, BiFunction<R,T,R> reducer)	Combine every upstream item with an accumulator value to produce a new accumulator value and emit the final accumulator value as a Single.
default Multi<T>	retry(long count)	Retry a failing upstream at most the given number of times before giving up.
default Multi<T>	retry(BiPredicate<? super Throwable, ? super Long> predicate)	Retry a failing upstream if the predicate returns true.
default <U> Multi<T>	retryWhen(BiFunction<? super Throwable, ? super Long, ? extends Flow.Publisher<U>> whenFunction)	Retry a failing upstream when the given function returns a publisher that signals an item.
default Multi<T>	skip(long skip)	Skip first n items, all the others are emitted.
default Multi<T>	switchIfEmpty(Flow.Publisher<T> other)	Switch to the other publisher if the upstream is empty.
default <U> Multi<T>	takeUntil(Flow.Publisher<U> other)	Relay upstream items until the other source signals an item or completes.
default Multi<T>	takeWhile(Predicate<? super T> predicate)	Take the longest prefix of elements from this stream that satisfy the given predicate.
default Multi<T>	timeout(long timeout, TimeUnit unit, ScheduledExecutorService executor)	Signals a TimeoutException if the upstream doesn't signal the next item, error or completion within the specified time.
default Multi<T>	timeout(long timeout, TimeUnit unit, ScheduledExecutorService executor, Flow.Publisher<T> fallback)	Switches to a fallback single if the upstream doesn't signal the next item, error or completion within the specified time.
default <U> U	to(Function<? super Multi<T>, ? extends U> converter)	Apply the given converter function to the current Multi instance and return the value returned by this function.

Methods inherited from interface Subscribable

subscribe, subscribe, subscribe, subscribe

Modifier and Type	Method	Description
default void	subscribe(Consumer<? super T> consumer)	Subscribe to this Single instance with the given delegate functions.
default void	subscribe(Consumer<? super T> consumer, Consumer<? super Throwable> errorConsumer)	Subscribe to this Single instance with the given delegate functions.
default void	subscribe(Consumer<? super T> consumer, Consumer<? super Throwable> errorConsumer, Runnable completeConsumer)	Subscribe to this Single instance with the given delegate functions.
default void	subscribe(Consumer<? super T> consumer, Consumer<? super Throwable> errorConsumer, Runnable completeConsumer, Consumer<? super Flow.Subscription> subscriptionConsumer)	Subscribe to this Single instance with the given delegate functions.

Method Details

create

public static <T> ConcatPublisher<T> create(Flow.Publisher<T> firstPublisher,
 Flow.Publisher<T> secondPublisher)

Create new ConcatPublisher.

Type Parameters:

T - item type

Parameters:

firstPublisher - first stream

secondPublisher - second stream

Returns:

ConcatPublisher

subscribe

public void subscribe(Flow.Subscriber<? super T> subscriber)

Specified by:

subscribe in interface Flow.Publisher<T>