Module io.helidon.microprofile.reactive

Package io.helidon.microprofile.reactive

Class HelidonReactivePublisherFactory

java.lang.Object

io.helidon.microprofile.reactive.HelidonReactivePublisherFactory

All Implemented Interfaces:

ReactiveStreamsFactory

public final class HelidonReactivePublisherFactory
extends Object
implements ReactiveStreamsFactory

Singleton factory for creating various builders out of sources.

See Also:

• INSTANCE

Field Summary

Fields

Modifier and Type	Field	Description
static final HelidonReactivePublisherFactory	INSTANCE	The singleton instance.

Constructor Summary

Constructors

Constructor	Description
HelidonReactivePublisherFactory()

Method Summary

Modifier and Type	Method	Description
<T> ProcessorBuilder<T,T>	builder()
<T> PublisherBuilder<T>	concat(PublisherBuilder<? extends T> a, PublisherBuilder<? extends T> b)
<T, R> ProcessorBuilder<T,R>	coupled(SubscriberBuilder<? super T,?> subscriber, PublisherBuilder<? extends R> publisher)
<T, R> ProcessorBuilder<T,R>	coupled(Subscriber<? super T> subscriber, Publisher<? extends R> publisher)
<T> PublisherBuilder<T>	empty()
<T> PublisherBuilder<T>	failed(Throwable t)
<T> PublisherBuilder<T>	fromCompletionStage(CompletionStage<? extends T> completionStage)
<T> PublisherBuilder<T>	fromCompletionStageNullable(CompletionStage<? extends T> completionStage)
<T> PublisherBuilder<T>	fromIterable(Iterable<? extends T> ts)
<T, R> ProcessorBuilder<T,R>	fromProcessor(Processor<? super T,? extends R> processor)
<T> PublisherBuilder<T>	fromPublisher(Publisher<? extends T> publisher)
<T> SubscriberBuilder<T,Void>	fromSubscriber(Subscriber<? super T> subscriber)
<T> PublisherBuilder<T>	generate(Supplier<? extends T> s)
<T> PublisherBuilder<T>	iterate(T seed, UnaryOperator<T> f)
<T> PublisherBuilder<T>	of(T t)
final <T> PublisherBuilder<T>	of(T... ts)
<T> PublisherBuilder<T>	ofNullable(T t)

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final HelidonReactivePublisherFactory INSTANCE

The singleton instance.

Constructor Details

HelidonReactivePublisherFactory

public HelidonReactivePublisherFactory()

Method Details

fromPublisher

public <T> PublisherBuilder<T> fromPublisher(Publisher<? extends T> publisher)

Specified by:

fromPublisher in interface ReactiveStreamsFactory

of

public <T> PublisherBuilder<T> of(T t)

Specified by:

of in interface ReactiveStreamsFactory

of

@SafeVarargs
public final <T> PublisherBuilder<T> of(T... ts)

Specified by:

of in interface ReactiveStreamsFactory

empty

public <T> PublisherBuilder<T> empty()

Specified by:

empty in interface ReactiveStreamsFactory

ofNullable

public <T> PublisherBuilder<T> ofNullable(T t)

Specified by:

ofNullable in interface ReactiveStreamsFactory

fromIterable

public <T> PublisherBuilder<T> fromIterable(Iterable<? extends T> ts)

Specified by:

fromIterable in interface ReactiveStreamsFactory

failed

public <T> PublisherBuilder<T> failed(Throwable t)

Specified by:

failed in interface ReactiveStreamsFactory

builder

public <T> ProcessorBuilder<T,T> builder()

Specified by:

builder in interface ReactiveStreamsFactory

fromProcessor

public <T,
R> ProcessorBuilder<T,R> fromProcessor(Processor<? super T,? extends R> processor)

Specified by:

fromProcessor in interface ReactiveStreamsFactory

fromSubscriber

public <T> SubscriberBuilder<T,Void> fromSubscriber(Subscriber<? super T> subscriber)

Specified by:

fromSubscriber in interface ReactiveStreamsFactory

iterate

public <T> PublisherBuilder<T> iterate(T seed,
 UnaryOperator<T> f)

Specified by:

iterate in interface ReactiveStreamsFactory

generate

public <T> PublisherBuilder<T> generate(Supplier<? extends T> s)

Specified by:

generate in interface ReactiveStreamsFactory

concat

public <T> PublisherBuilder<T> concat(PublisherBuilder<? extends T> a,
 PublisherBuilder<? extends T> b)

Specified by:

concat in interface ReactiveStreamsFactory

fromCompletionStage

public <T> PublisherBuilder<T> fromCompletionStage(CompletionStage<? extends T> completionStage)

Specified by:

fromCompletionStage in interface ReactiveStreamsFactory

fromCompletionStageNullable

public <T> PublisherBuilder<T> fromCompletionStageNullable(CompletionStage<? extends T> completionStage)

Specified by:

fromCompletionStageNullable in interface ReactiveStreamsFactory

coupled

public <T,
R> ProcessorBuilder<T,R> coupled(SubscriberBuilder<? super T,?> subscriber,
 PublisherBuilder<? extends R> publisher)

Specified by:

coupled in interface ReactiveStreamsFactory

coupled

public <T,
R> ProcessorBuilder<T,R> coupled(Subscriber<? super T> subscriber,
 Publisher<? extends R> publisher)

Specified by:

coupled in interface ReactiveStreamsFactory