Module io.helidon.common.reactive

Package io.helidon.common.reactive

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 java.lang.Object

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

Methods inherited from interface io.helidon.common.reactive.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

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

subscribe, subscribe, subscribe, subscribe

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>