Package hu.akarnokd.rxjava3.mprs

Class RxJavaPublisherFactory

  • All Implemented Interfaces:
    org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory
    public final class RxJavaPublisherFactory
extends java.lang.Object
implements org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory
    Constructs RxJava-based PublisherBuilders.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory INSTANCE
      The (almost) singleton instance.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​T> builder()  
      <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> concat​(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends T> a, org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends T> b)  
      <T,​R>
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>      		 coupled​(org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? super T,​?> subscriber, org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends R> publisher)  
      <T,​R>
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>      		 coupled​(org.reactivestreams.Subscriber<? super T> subscriber, org.reactivestreams.Publisher<? extends R> publisher)  
      <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> empty()  
      <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> failed​(java.lang.Throwable t)  
      <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> fromCompletionStage​(java.util.concurrent.CompletionStage<? extends T> completionStage)  
      <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> fromCompletionStageNullable​(java.util.concurrent.CompletionStage<? extends T> completionStage)  
      <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> fromIterable​(java.lang.Iterable<? extends T> ts)  
      <T,​R>
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>      		 fromProcessor​(org.reactivestreams.Processor<? super T,​? extends R> processor)  
      <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> fromPublisher​(org.reactivestreams.Publisher<? extends T> publisher)  
      <T> org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.lang.Void> fromSubscriber​(org.reactivestreams.Subscriber<? super T> subscriber)  
      <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> generate​(java.util.function.Supplier<? extends T> s)  
      <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> iterate​(T seed, java.util.function.UnaryOperator<T> f)  
      <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> of​(T t)  
      <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> of​(T... ts)  
      <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> ofNullable​(T t)  

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • INSTANCE

        public static final org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory INSTANCE
        The (almost) singleton instance.

    • Constructor Detail

      • RxJavaPublisherFactory

        public RxJavaPublisherFactory()

    • Method Detail

      • fromPublisher

        public <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> fromPublisher​(org.reactivestreams.Publisher<? extends T> publisher)
        Specified by:
        fromPublisher in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • of

        public <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> of​(T t)
        Specified by:
        of in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • of

        @SafeVarargs
public final <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> of​(T... ts)
        Specified by:
        of in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • empty

        public <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> empty()
        Specified by:
        empty in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • ofNullable

        public <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> ofNullable​(T t)
        Specified by:
        ofNullable in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • fromIterable

        public <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> fromIterable​(java.lang.Iterable<? extends T> ts)
        Specified by:
        fromIterable in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • failed

        public <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> failed​(java.lang.Throwable t)
        Specified by:
        failed in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • builder

        public <T> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​T> builder()
        Specified by:
        builder in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • fromProcessor

        public <T,​R> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> fromProcessor​(org.reactivestreams.Processor<? super T,​? extends R> processor)
        Specified by:
        fromProcessor in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • fromSubscriber

        public <T> org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.lang.Void> fromSubscriber​(org.reactivestreams.Subscriber<? super T> subscriber)
        Specified by:
        fromSubscriber in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • iterate

        public <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> iterate​(T seed,
                                                                                           java.util.function.UnaryOperator<T> f)
        Specified by:
        iterate in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • generate

        public <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> generate​(java.util.function.Supplier<? extends T> s)
        Specified by:
        generate in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • concat

        public <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> concat​(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends T> a,
                                                                                          org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends T> b)
        Specified by:
        concat in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • fromCompletionStage

        public <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> fromCompletionStage​(java.util.concurrent.CompletionStage<? extends T> completionStage)
        Specified by:
        fromCompletionStage in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • fromCompletionStageNullable

        public <T> org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<T> fromCompletionStageNullable​(java.util.concurrent.CompletionStage<? extends T> completionStage)
        Specified by:
        fromCompletionStageNullable in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • coupled

        public <T,​R> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> coupled​(org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? super T,​?> subscriber,
                                                                                                           org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends R> publisher)
        Specified by:
        coupled in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory

      • coupled

        public <T,​R> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> coupled​(org.reactivestreams.Subscriber<? super T> subscriber,
                                                                                                           org.reactivestreams.Publisher<? extends R> publisher)
        Specified by:
        coupled in interface org.eclipse.microprofile.reactive.streams.operators.ReactiveStreamsFactory