Class ReactiveStreamsFactoryImpl
- java.lang.Object
-
- org.eclipse.microprofile.reactive.streams.operators.core.ReactiveStreamsFactoryImpl
-
- All Implemented Interfaces:
ReactiveStreamsFactory
public class ReactiveStreamsFactoryImpl extends Object implements ReactiveStreamsFactory
-
-
Constructor Summary
Constructors Constructor Description ReactiveStreamsFactoryImpl()
-
Method Summary
All Methods Instance Methods Concrete Methods 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(org.reactivestreams.Subscriber<? super T> subscriber, org.reactivestreams.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(org.reactivestreams.Processor<? super T,? extends R> processor)
<T> PublisherBuilder<T>
fromPublisher(org.reactivestreams.Publisher<? extends T> publisher)
<T> SubscriberBuilder<T,Void>
fromSubscriber(org.reactivestreams.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)
<T> PublisherBuilder<T>
of(T... ts)
<T> PublisherBuilder<T>
ofNullable(T t)
-
-
-
Method Detail
-
fromPublisher
public <T> PublisherBuilder<T> fromPublisher(org.reactivestreams.Publisher<? extends T> publisher)
- Specified by:
fromPublisher
in interfaceReactiveStreamsFactory
-
of
public <T> PublisherBuilder<T> of(T t)
- Specified by:
of
in interfaceReactiveStreamsFactory
-
of
public <T> PublisherBuilder<T> of(T... ts)
- Specified by:
of
in interfaceReactiveStreamsFactory
-
empty
public <T> PublisherBuilder<T> empty()
- Specified by:
empty
in interfaceReactiveStreamsFactory
-
ofNullable
public <T> PublisherBuilder<T> ofNullable(T t)
- Specified by:
ofNullable
in interfaceReactiveStreamsFactory
-
fromIterable
public <T> PublisherBuilder<T> fromIterable(Iterable<? extends T> ts)
- Specified by:
fromIterable
in interfaceReactiveStreamsFactory
-
failed
public <T> PublisherBuilder<T> failed(Throwable t)
- Specified by:
failed
in interfaceReactiveStreamsFactory
-
builder
public <T> ProcessorBuilder<T,T> builder()
- Specified by:
builder
in interfaceReactiveStreamsFactory
-
fromProcessor
public <T,R> ProcessorBuilder<T,R> fromProcessor(org.reactivestreams.Processor<? super T,? extends R> processor)
- Specified by:
fromProcessor
in interfaceReactiveStreamsFactory
-
fromSubscriber
public <T> SubscriberBuilder<T,Void> fromSubscriber(org.reactivestreams.Subscriber<? super T> subscriber)
- Specified by:
fromSubscriber
in interfaceReactiveStreamsFactory
-
iterate
public <T> PublisherBuilder<T> iterate(T seed, UnaryOperator<T> f)
- Specified by:
iterate
in interfaceReactiveStreamsFactory
-
generate
public <T> PublisherBuilder<T> generate(Supplier<? extends T> s)
- Specified by:
generate
in interfaceReactiveStreamsFactory
-
concat
public <T> PublisherBuilder<T> concat(PublisherBuilder<? extends T> a, PublisherBuilder<? extends T> b)
- Specified by:
concat
in interfaceReactiveStreamsFactory
-
fromCompletionStage
public <T> PublisherBuilder<T> fromCompletionStage(CompletionStage<? extends T> completionStage)
- Specified by:
fromCompletionStage
in interfaceReactiveStreamsFactory
-
fromCompletionStageNullable
public <T> PublisherBuilder<T> fromCompletionStageNullable(CompletionStage<? extends T> completionStage)
- Specified by:
fromCompletionStageNullable
in interfaceReactiveStreamsFactory
-
coupled
public <T,R> ProcessorBuilder<T,R> coupled(SubscriberBuilder<? super T,?> subscriber, PublisherBuilder<? extends R> publisher)
- Specified by:
coupled
in interfaceReactiveStreamsFactory
-
coupled
public <T,R> ProcessorBuilder<T,R> coupled(org.reactivestreams.Subscriber<? super T> subscriber, org.reactivestreams.Publisher<? extends R> publisher)
- Specified by:
coupled
in interfaceReactiveStreamsFactory
-
-