Package hu.akarnokd.rxjava3.mprs

Class RxJavaProcessorBuilder<T,​R>

  • Type Parameters:
    T - the input type of the sequence
    R - the output value type
    All Implemented Interfaces:
    org.eclipse.microprofile.reactive.streams.operators.ConnectingOperators<R>, org.eclipse.microprofile.reactive.streams.operators.ConsumingOperators<R>, org.eclipse.microprofile.reactive.streams.operators.ErrorHandlingOperators<R>, org.eclipse.microprofile.reactive.streams.operators.FilteringOperators<R>, org.eclipse.microprofile.reactive.streams.operators.PeekingOperators<R>, org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>, org.eclipse.microprofile.reactive.streams.operators.spi.ToGraphable, org.eclipse.microprofile.reactive.streams.operators.TransformingOperators<R>
    public final class RxJavaProcessorBuilder<T,​R>
extends java.lang.Object
implements org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>, org.eclipse.microprofile.reactive.streams.operators.spi.ToGraphable
    Builds a Flowable-based sequence by applying operators one after the other.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.reactivestreams.Processor<T,​R> buildRs()  
      org.reactivestreams.Processor<T,​R> buildRs​(org.eclipse.microprofile.reactive.streams.operators.spi.ReactiveStreamsEngine engine)  
      org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.lang.Void> cancel()  
      <S> org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​S> collect​(java.util.function.Supplier<S> supplier, java.util.function.BiConsumer<S,​? super R> accumulator)  
      <S,​A>
      org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​S>      		 collect​(java.util.stream.Collector<? super R,​A,​S> collector)  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> distinct()  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> dropWhile​(java.util.function.Predicate<? super R> predicate)  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> filter​(java.util.function.Predicate<? super R> predicate)  
      org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.util.Optional<R>> findFirst()  
      <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> flatMap​(java.util.function.Function<? super R,​? extends org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends S>> mapper)  
      <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> flatMapCompletionStage​(java.util.function.Function<? super R,​? extends java.util.concurrent.CompletionStage<? extends S>> mapper)  
      <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> flatMapIterable​(java.util.function.Function<? super R,​? extends java.lang.Iterable<? extends S>> mapper)  
      <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> flatMapRsPublisher​(java.util.function.Function<? super R,​? extends org.reactivestreams.Publisher<? extends S>> mapper)  
      org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.lang.Void> forEach​(java.util.function.Consumer<? super R> action)  
      org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.lang.Void> ignore()  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> limit​(long maxSize)  
      <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> map​(java.util.function.Function<? super R,​? extends S> mapper)  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> onComplete​(java.lang.Runnable action)  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> onError​(java.util.function.Consumer<java.lang.Throwable> errorHandler)  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> onErrorResume​(java.util.function.Function<java.lang.Throwable,​? extends R> errorHandler)  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> onErrorResumeWith​(java.util.function.Function<java.lang.Throwable,​? extends org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends R>> errorHandler)  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> onErrorResumeWithRsPublisher​(java.util.function.Function<java.lang.Throwable,​? extends org.reactivestreams.Publisher<? extends R>> errorHandler)  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> onTerminate​(java.lang.Runnable action)  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> peek​(java.util.function.Consumer<? super R> consumer)  
      org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.util.Optional<R>> reduce​(java.util.function.BinaryOperator<R> accumulator)  
      org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​R> reduce​(R identity, java.util.function.BinaryOperator<R> accumulator)  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> skip​(long n)  
      org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> takeWhile​(java.util.function.Predicate<? super R> predicate)  
      <S> org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​S> to​(org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? super R,​? extends S> subscriber)  
      org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.lang.Void> to​(org.reactivestreams.Subscriber<? super R> subscriber)  
      org.eclipse.microprofile.reactive.streams.operators.spi.Graph toGraph()  
      org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.util.List<R>> toList()  
      Flowable transform​(Flowable input)  
      <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> via​(org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<? super R,​? extends S> processor)  
      <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> via​(org.reactivestreams.Processor<? super R,​? extends S> processor)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • RxJavaProcessorBuilder

        public RxJavaProcessorBuilder()

      • RxJavaProcessorBuilder

        public RxJavaProcessorBuilder​(org.reactivestreams.Processor<? super T,​? extends R> processor)

    • Method Detail

      • map

        public <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> map​(java.util.function.Function<? super R,​? extends S> mapper)
        Specified by:
        map in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>
        Specified by:
        map in interface org.eclipse.microprofile.reactive.streams.operators.TransformingOperators<T>

      • flatMap

        public <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> flatMap​(java.util.function.Function<? super R,​? extends org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends S>> mapper)
        Specified by:
        flatMap in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>
        Specified by:
        flatMap in interface org.eclipse.microprofile.reactive.streams.operators.TransformingOperators<T>

      • flatMapRsPublisher

        public <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> flatMapRsPublisher​(java.util.function.Function<? super R,​? extends org.reactivestreams.Publisher<? extends S>> mapper)
        Specified by:
        flatMapRsPublisher in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>
        Specified by:
        flatMapRsPublisher in interface org.eclipse.microprofile.reactive.streams.operators.TransformingOperators<T>

      • flatMapCompletionStage

        public <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> flatMapCompletionStage​(java.util.function.Function<? super R,​? extends java.util.concurrent.CompletionStage<? extends S>> mapper)
        Specified by:
        flatMapCompletionStage in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>
        Specified by:
        flatMapCompletionStage in interface org.eclipse.microprofile.reactive.streams.operators.TransformingOperators<T>

      • flatMapIterable

        public <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> flatMapIterable​(java.util.function.Function<? super R,​? extends java.lang.Iterable<? extends S>> mapper)
        Specified by:
        flatMapIterable in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>
        Specified by:
        flatMapIterable in interface org.eclipse.microprofile.reactive.streams.operators.TransformingOperators<T>

      • filter

        public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> filter​(java.util.function.Predicate<? super R> predicate)
        Specified by:
        filter in interface org.eclipse.microprofile.reactive.streams.operators.FilteringOperators<T>
        Specified by:
        filter in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • distinct

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

      • limit

        public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> limit​(long maxSize)
        Specified by:
        limit in interface org.eclipse.microprofile.reactive.streams.operators.FilteringOperators<T>
        Specified by:
        limit in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • skip

        public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> skip​(long n)
        Specified by:
        skip in interface org.eclipse.microprofile.reactive.streams.operators.FilteringOperators<T>
        Specified by:
        skip in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • takeWhile

        public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> takeWhile​(java.util.function.Predicate<? super R> predicate)
        Specified by:
        takeWhile in interface org.eclipse.microprofile.reactive.streams.operators.FilteringOperators<T>
        Specified by:
        takeWhile in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • dropWhile

        public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> dropWhile​(java.util.function.Predicate<? super R> predicate)
        Specified by:
        dropWhile in interface org.eclipse.microprofile.reactive.streams.operators.FilteringOperators<T>
        Specified by:
        dropWhile in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • peek

        public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> peek​(java.util.function.Consumer<? super R> consumer)
        Specified by:
        peek in interface org.eclipse.microprofile.reactive.streams.operators.PeekingOperators<T>
        Specified by:
        peek in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • onError

        public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> onError​(java.util.function.Consumer<java.lang.Throwable> errorHandler)
        Specified by:
        onError in interface org.eclipse.microprofile.reactive.streams.operators.PeekingOperators<T>
        Specified by:
        onError in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • onTerminate

        public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> onTerminate​(java.lang.Runnable action)
        Specified by:
        onTerminate in interface org.eclipse.microprofile.reactive.streams.operators.PeekingOperators<T>
        Specified by:
        onTerminate in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • onComplete

        public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> onComplete​(java.lang.Runnable action)
        Specified by:
        onComplete in interface org.eclipse.microprofile.reactive.streams.operators.PeekingOperators<T>
        Specified by:
        onComplete in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • forEach

        public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.lang.Void> forEach​(java.util.function.Consumer<? super R> action)
        Specified by:
        forEach in interface org.eclipse.microprofile.reactive.streams.operators.ConsumingOperators<T>
        Specified by:
        forEach in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • ignore

        public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.lang.Void> ignore()
        Specified by:
        ignore in interface org.eclipse.microprofile.reactive.streams.operators.ConsumingOperators<T>
        Specified by:
        ignore in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • cancel

        public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.lang.Void> cancel()
        Specified by:
        cancel in interface org.eclipse.microprofile.reactive.streams.operators.ConsumingOperators<T>
        Specified by:
        cancel in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • reduce

        public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​R> reduce​(R identity,
                                                                                               java.util.function.BinaryOperator<R> accumulator)
        Specified by:
        reduce in interface org.eclipse.microprofile.reactive.streams.operators.ConsumingOperators<T>
        Specified by:
        reduce in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • reduce

        public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.util.Optional<R>> reduce​(java.util.function.BinaryOperator<R> accumulator)
        Specified by:
        reduce in interface org.eclipse.microprofile.reactive.streams.operators.ConsumingOperators<T>
        Specified by:
        reduce in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • findFirst

        public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.util.Optional<R>> findFirst()
        Specified by:
        findFirst in interface org.eclipse.microprofile.reactive.streams.operators.ConsumingOperators<T>
        Specified by:
        findFirst in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • collect

        public <S,​A> org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​S> collect​(java.util.stream.Collector<? super R,​A,​S> collector)
        Specified by:
        collect in interface org.eclipse.microprofile.reactive.streams.operators.ConsumingOperators<T>
        Specified by:
        collect in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • collect

        public <S> org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​S> collect​(java.util.function.Supplier<S> supplier,
                                                                                                    java.util.function.BiConsumer<S,​? super R> accumulator)
        Specified by:
        collect in interface org.eclipse.microprofile.reactive.streams.operators.ConsumingOperators<T>
        Specified by:
        collect in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • toList

        public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​java.util.List<R>> toList()
        Specified by:
        toList in interface org.eclipse.microprofile.reactive.streams.operators.ConsumingOperators<T>
        Specified by:
        toList in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • onErrorResume

        public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> onErrorResume​(java.util.function.Function<java.lang.Throwable,​? extends R> errorHandler)
        Specified by:
        onErrorResume in interface org.eclipse.microprofile.reactive.streams.operators.ErrorHandlingOperators<T>
        Specified by:
        onErrorResume in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • onErrorResumeWith

        public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> onErrorResumeWith​(java.util.function.Function<java.lang.Throwable,​? extends org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends R>> errorHandler)
        Specified by:
        onErrorResumeWith in interface org.eclipse.microprofile.reactive.streams.operators.ErrorHandlingOperators<T>
        Specified by:
        onErrorResumeWith in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • onErrorResumeWithRsPublisher

        public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R> onErrorResumeWithRsPublisher​(java.util.function.Function<java.lang.Throwable,​? extends org.reactivestreams.Publisher<? extends R>> errorHandler)
        Specified by:
        onErrorResumeWithRsPublisher in interface org.eclipse.microprofile.reactive.streams.operators.ErrorHandlingOperators<T>
        Specified by:
        onErrorResumeWithRsPublisher in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • to

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

      • to

        public <S> org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<T,​S> to​(org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? super R,​? extends S> subscriber)
        Specified by:
        to in interface org.eclipse.microprofile.reactive.streams.operators.ConnectingOperators<T>
        Specified by:
        to in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • via

        public <S> org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​S> via​(org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<? super R,​? extends S> processor)
        Specified by:
        via in interface org.eclipse.microprofile.reactive.streams.operators.ConnectingOperators<T>
        Specified by:
        via in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • via

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

      • buildRs

        public org.reactivestreams.Processor<T,​R> buildRs()
        Specified by:
        buildRs in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • buildRs

        public org.reactivestreams.Processor<T,​R> buildRs​(org.eclipse.microprofile.reactive.streams.operators.spi.ReactiveStreamsEngine engine)
        Specified by:
        buildRs in interface org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<T,​R>

      • toGraph

        public org.eclipse.microprofile.reactive.streams.operators.spi.Graph toGraph()
        Specified by:
        toGraph in interface org.eclipse.microprofile.reactive.streams.operators.spi.ToGraphable