B C D E F G H I L M O P R S T V
All Classes All Packages

B

buildCompletion(Graph) - Method in enum hu.akarnokd.rxjava3.mprs.RxJavaEngine

builder() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

buildGraph() - Static method in class hu.akarnokd.rxjava3.mprs.RxJavaMicroprofilePlugins

Returns true if the Stage graph should be built

buildProcessor(Graph) - Method in enum hu.akarnokd.rxjava3.mprs.RxJavaEngine

buildPublisher(Graph) - Method in enum hu.akarnokd.rxjava3.mprs.RxJavaEngine

buildRs() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

buildRs() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

buildRs(ReactiveStreamsEngine) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

buildRs(ReactiveStreamsEngine) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

buildSubscriber(Graph) - Method in enum hu.akarnokd.rxjava3.mprs.RxJavaEngine

C

cancel() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

cancel() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

collect(Supplier<R>, BiConsumer<R, ? super T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

collect(Supplier<S>, BiConsumer<S, ? super R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

collect(Collector<? super R, A, S>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

collect(Collector<? super T, A, R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

concat(PublisherBuilder<? extends T>, PublisherBuilder<? extends T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

coupled(SubscriberBuilder<? super T, ?>, PublisherBuilder<? extends R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

coupled(Subscriber<? super T>, Publisher<? extends R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

D

disableBuildGraph() - Static method in class hu.akarnokd.rxjava3.mprs.RxJavaMicroprofilePlugins

Globally disable building the Stage graph along with the Flowable graph.

disableImmutableBuilders() - Static method in class hu.akarnokd.rxjava3.mprs.RxJavaMicroprofilePlugins

Globally disable using immutable builders.

distinct() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

distinct() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

dropWhile(Predicate<? super R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

dropWhile(Predicate<? super T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

E

empty() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

enableBuildGraph() - Static method in class hu.akarnokd.rxjava3.mprs.RxJavaMicroprofilePlugins

Globally enable building the Stage graph along with the Flowable graph.

enableImmutableBuilders() - Static method in class hu.akarnokd.rxjava3.mprs.RxJavaMicroprofilePlugins

Globally enable using immutable builders.

F

failed(Throwable) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

filter(Predicate<? super R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

filter(Predicate<? super T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

findFirst() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

findFirst() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

flatMap(Function<? super R, ? extends PublisherBuilder<? extends S>>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

flatMap(Function<? super T, ? extends PublisherBuilder<? extends S>>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

flatMapCompletionStage(Function<? super R, ? extends CompletionStage<? extends S>>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

flatMapCompletionStage(Function<? super T, ? extends CompletionStage<? extends S>>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

flatMapIterable(Function<? super R, ? extends Iterable<? extends S>>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

flatMapIterable(Function<? super T, ? extends Iterable<? extends S>>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

flatMapRsPublisher(Function<? super R, ? extends Publisher<? extends S>>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

flatMapRsPublisher(Function<? super T, ? extends Publisher<? extends S>>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

forEach(Consumer<? super R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

forEach(Consumer<? super T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

fromCompletionStage(CompletionStage<? extends T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

fromCompletionStageNullable(CompletionStage<? extends T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

fromIterable(Iterable<? extends T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

fromProcessor(Processor<? super T, ? extends R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

fromPublisher(Publisher<? extends T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

fromSubscriber(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

G

generate(Supplier<? extends T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

H

hu.akarnokd.rxjava3.mprs - package hu.akarnokd.rxjava3.mprs

I

ignore() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

ignore() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

immutableBuilders() - Static method in class hu.akarnokd.rxjava3.mprs.RxJavaMicroprofilePlugins

Retruns true if builders are immutable.

INSTANCE - hu.akarnokd.rxjava3.mprs.RxJavaEngine

INSTANCE - Static variable in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

The (almost) singleton instance.

iterate(T, UnaryOperator<T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

L

limit(long) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

limit(long) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

M

map(Function<? super R, ? extends S>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

map(Function<? super T, ? extends R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

O

of(T) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

of(T...) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

ofNullable(T) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

onComplete(Runnable) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

onComplete(Runnable) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

onError(Consumer<Throwable>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

onError(Consumer<Throwable>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

onErrorResume(Function<Throwable, ? extends R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

onErrorResume(Function<Throwable, ? extends T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

onErrorResumeWith(Function<Throwable, ? extends PublisherBuilder<? extends R>>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

onErrorResumeWith(Function<Throwable, ? extends PublisherBuilder<? extends T>>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

onErrorResumeWithRsPublisher(Function<Throwable, ? extends Publisher<? extends R>>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

onErrorResumeWithRsPublisher(Function<Throwable, ? extends Publisher<? extends T>>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

onTerminate(Runnable) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

onTerminate(Runnable) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

P

peek(Consumer<? super R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

peek(Consumer<? super T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

R

reduce(BinaryOperator<R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

reduce(BinaryOperator<T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

reduce(R, BinaryOperator<R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

reduce(T, BinaryOperator<T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

RxJavaEngine - Enum in hu.akarnokd.rxjava3.mprs

An RxJava-based ReactiveStreamsEngine that translates the assembly instructions in a Graph into RxJava Flowable-based flows and components.

RxJavaMicroprofilePlugins - Class in hu.akarnokd.rxjava3.mprs

Hooks and global settings for the RxJava Microprofile Reactive Streams Operators services.

RxJavaProcessorBuilder<T,R> - Class in hu.akarnokd.rxjava3.mprs

Builds a Flowable-based sequence by applying operators one after the other.

RxJavaProcessorBuilder() - Constructor for class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

RxJavaProcessorBuilder(Processor<? super T, ? extends R>) - Constructor for class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

RxJavaPublisherBuilder<T> - Class in hu.akarnokd.rxjava3.mprs

Builds a Flowable-based sequence by applying operators one after the other.

RxJavaPublisherBuilder(Flowable<T>) - Constructor for class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

Create a builder with the given Flowable as the source.

RxJavaPublisherFactory - Class in hu.akarnokd.rxjava3.mprs

Constructs RxJava-based PublisherBuilders.

RxJavaPublisherFactory() - Constructor for class hu.akarnokd.rxjava3.mprs.RxJavaPublisherFactory

S

skip(long) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

skip(long) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

T

takeWhile(Predicate<? super R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

takeWhile(Predicate<? super T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

to(SubscriberBuilder<? super R, ? extends S>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

to(SubscriberBuilder<? super T, ? extends R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

to(Subscriber<? super R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

to(Subscriber<? super T>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

toGraph() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

toGraph() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

toList() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

toList() - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

transform(Flowable) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

V

valueOf(String) - Static method in enum hu.akarnokd.rxjava3.mprs.RxJavaEngine

Returns the enum constant of this type with the specified name.

values() - Static method in enum hu.akarnokd.rxjava3.mprs.RxJavaEngine

Returns an array containing the constants of this enum type, in the order they are declared.

via(ProcessorBuilder<? super R, ? extends S>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

via(ProcessorBuilder<? super T, ? extends R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

via(Processor<? super R, ? extends S>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaProcessorBuilder

via(Processor<? super T, ? extends R>) - Method in class hu.akarnokd.rxjava3.mprs.RxJavaPublisherBuilder

B C D E F G H I L M O P R S T V
All Classes All Packages