public class DefaultReactiveStreamsFactory extends Object implements ReactiveStreamsFactory
ReactiveStreamsFactory
that delegates to ReactiveStreams
static factory
methods.Constructor and Description |
---|
DefaultReactiveStreamsFactory() |
Modifier and Type | Method and Description |
---|---|
<T> ProcessorBuilder<T,T> |
builder() |
<T> PublisherBuilder<T> |
concat(PublisherBuilder<? extends T> a,
PublisherBuilder<? extends T> b) |
<T,R> ProcessorBuilder<T,R> |
coupled(org.reactivestreams.Subscriber<? super T> subscriber,
org.reactivestreams.Publisher<? extends R> publisher) |
<T,R> ProcessorBuilder<T,R> |
coupled(SubscriberBuilder<? super T,?> subscriber,
PublisherBuilder<? 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... ts) |
<T> PublisherBuilder<T> |
of(T t) |
<T> PublisherBuilder<T> |
ofNullable(T t) |
public <T> PublisherBuilder<T> fromPublisher(org.reactivestreams.Publisher<? extends T> publisher)
fromPublisher
in interface ReactiveStreamsFactory
public <T> PublisherBuilder<T> of(T t)
of
in interface ReactiveStreamsFactory
public <T> PublisherBuilder<T> of(T... ts)
of
in interface ReactiveStreamsFactory
public <T> PublisherBuilder<T> empty()
empty
in interface ReactiveStreamsFactory
public <T> PublisherBuilder<T> ofNullable(T t)
ofNullable
in interface ReactiveStreamsFactory
public <T> PublisherBuilder<T> fromIterable(Iterable<? extends T> ts)
fromIterable
in interface ReactiveStreamsFactory
public <T> PublisherBuilder<T> failed(Throwable t)
failed
in interface ReactiveStreamsFactory
public <T> ProcessorBuilder<T,T> builder()
builder
in interface ReactiveStreamsFactory
public <T,R> ProcessorBuilder<T,R> fromProcessor(org.reactivestreams.Processor<? super T,? extends R> processor)
fromProcessor
in interface ReactiveStreamsFactory
public <T> SubscriberBuilder<T,Void> fromSubscriber(org.reactivestreams.Subscriber<? super T> subscriber)
fromSubscriber
in interface ReactiveStreamsFactory
public <T> PublisherBuilder<T> iterate(T seed, UnaryOperator<T> f)
iterate
in interface ReactiveStreamsFactory
public <T> PublisherBuilder<T> generate(Supplier<? extends T> s)
generate
in interface ReactiveStreamsFactory
public <T> PublisherBuilder<T> concat(PublisherBuilder<? extends T> a, PublisherBuilder<? extends T> b)
concat
in interface ReactiveStreamsFactory
public <T> PublisherBuilder<T> fromCompletionStage(CompletionStage<? extends T> completionStage)
fromCompletionStage
in interface ReactiveStreamsFactory
public <T> PublisherBuilder<T> fromCompletionStageNullable(CompletionStage<? extends T> completionStage)
fromCompletionStageNullable
in interface ReactiveStreamsFactory
public <T,R> ProcessorBuilder<T,R> coupled(SubscriberBuilder<? super T,?> subscriber, PublisherBuilder<? extends R> publisher)
coupled
in interface ReactiveStreamsFactory
public <T,R> ProcessorBuilder<T,R> coupled(org.reactivestreams.Subscriber<? super T> subscriber, org.reactivestreams.Publisher<? extends R> publisher)
coupled
in interface ReactiveStreamsFactory
Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.