A B C D E F G I L M O P R S T V W

A

apply(Flowable<I>) - Method in interface io.smallrye.reactive.streams.operators.ProcessingStage

Adapts the streams.

apply(Flowable<I>) - Method in interface io.smallrye.reactive.streams.operators.TerminalStage

Creates the CompletionStage called when the embedded logic has completed or failed.

apply(Flowable<T>) - Static method in class io.smallrye.reactive.streams.spi.Transformer

Calls the model.

apply(Flowable) - Method in class io.smallrye.reactive.streams.vertx.VertxExecutionModel

B

buildCompletion(Graph) - Method in class io.smallrye.reactive.streams.Engine

buildProcessor(Graph) - Method in class io.smallrye.reactive.streams.Engine

buildPublisher(Graph) - Method in class io.smallrye.reactive.streams.Engine

buildSubscriber(Graph) - Method in class io.smallrye.reactive.streams.Engine

C

cancel() - Method in class io.smallrye.reactive.streams.utils.EmptySubscription

cancel() - Method in class io.smallrye.reactive.streams.utils.WrappedSubscription

cancelIfNotSubscribed() - Method in class io.smallrye.reactive.streams.utils.CancellablePublisher

CancellablePublisher<T> - Class in io.smallrye.reactive.streams.utils

Wrapped a source publisher and make it cancellable on demand.

CancellablePublisher(Publisher<T>) - Constructor for class io.smallrye.reactive.streams.utils.CancellablePublisher

CancellationSubscriber<T> - Class in io.smallrye.reactive.streams.utils

CancellationSubscriber() - Constructor for class io.smallrye.reactive.streams.utils.CancellationSubscriber

CancelStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of Stage.Cancel.

CancelStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.CancelStageFactory

cast(Function<?, ?>) - Static method in class io.smallrye.reactive.streams.utils.Casts

cast(Predicate<?>) - Static method in class io.smallrye.reactive.streams.utils.Casts

cast(ProcessingStage<?, ?>) - Static method in class io.smallrye.reactive.streams.utils.Casts

cast(Processor<?, ?>) - Static method in class io.smallrye.reactive.streams.utils.Casts

cast(CompletionStage<?>) - Static method in class io.smallrye.reactive.streams.utils.Casts

Casts - Class in io.smallrye.reactive.streams.utils

Cosmetic cast / generic / erasure fixes.

CollectStageFactory - Class in io.smallrye.reactive.streams.stages

Implement the Stage.Collect stage.

CollectStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.CollectStageFactory

CompletableConverter - Class in io.smallrye.reactive.converters.rxjava1

Converter handling the RX Java 1 Completable type.

CompletableConverter() - Constructor for class io.smallrye.reactive.converters.rxjava1.CompletableConverter

CompletableConverter - Class in io.smallrye.reactive.converters.rxjava2

Converter handling the RX Java 2 Completable type.

CompletableConverter() - Constructor for class io.smallrye.reactive.converters.rxjava2.CompletableConverter

CompletionStageToPublisher - Class in io.smallrye.reactive.streams.utils

ConcatStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.Concat stage.

ConcatStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.ConcatStageFactory

ConnectableProcessor<T> - Class in io.smallrye.reactive.streams.utils

A processor forwarding to a subscriber.

ConnectableProcessor() - Constructor for class io.smallrye.reactive.streams.utils.ConnectableProcessor

CoupledStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.Coupled stage.

CoupledStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.CoupledStageFactory

CouplingProcessor<I,O> - Class in io.smallrye.reactive.streams.utils

CouplingProcessor(Publisher<I>, Subscriber<I>, Publisher<O>) - Constructor for class io.smallrye.reactive.streams.utils.CouplingProcessor

create(Engine, T) - Method in interface io.smallrye.reactive.streams.operators.ProcessingStageFactory

Creates the instance.

create(Engine, T) - Method in class io.smallrye.reactive.streams.operators.ProcessorOperator

create(Engine, T) - Method in class io.smallrye.reactive.streams.operators.PublisherOperator

create(Engine, T) - Method in interface io.smallrye.reactive.streams.operators.PublisherStageFactory

Creates the instance.

create(Engine, T) - Method in class io.smallrye.reactive.streams.operators.TerminalOperator

create(Engine, T) - Method in interface io.smallrye.reactive.streams.operators.TerminalStageFactory

Creates the instance.

create(Engine, Stage.Cancel) - Method in class io.smallrye.reactive.streams.stages.CancelStageFactory

create(Engine, Stage.Collect) - Method in class io.smallrye.reactive.streams.stages.CollectStageFactory

create(Engine, Stage.Concat) - Method in class io.smallrye.reactive.streams.stages.ConcatStageFactory

create(Engine, Stage.Coupled) - Method in class io.smallrye.reactive.streams.stages.CoupledStageFactory

create(Engine, Stage.Distinct) - Method in class io.smallrye.reactive.streams.stages.DistinctStageFactory

create(Engine, Stage.DropWhile) - Method in class io.smallrye.reactive.streams.stages.DropWhileStageFactory

create(Engine, Stage.Failed) - Method in class io.smallrye.reactive.streams.stages.FailedPublisherStageFactory

create(Engine, Stage.Filter) - Method in class io.smallrye.reactive.streams.stages.FilterStageFactory

create(Engine, Stage.FindFirst) - Method in class io.smallrye.reactive.streams.stages.FindFirstStageFactory

create(Engine, Stage.FlatMapCompletionStage) - Method in class io.smallrye.reactive.streams.stages.FlatMapCompletionStageFactory

create(Engine, Stage.FlatMapIterable) - Method in class io.smallrye.reactive.streams.stages.FlatMapIterableStageFactory

create(Engine, Stage.FlatMap) - Method in class io.smallrye.reactive.streams.stages.FlatMapStageFactory

create(Engine, Stage.FromCompletionStage) - Method in class io.smallrye.reactive.streams.stages.FromCompletionStageFactory

create(Engine, Stage.FromCompletionStageNullable) - Method in class io.smallrye.reactive.streams.stages.FromCompletionStageNullableFactory

create(Engine, Stage.Of) - Method in class io.smallrye.reactive.streams.stages.FromIterableStageFactory

create(Engine, Stage.PublisherStage) - Method in class io.smallrye.reactive.streams.stages.FromPublisherStageFactory

create(Engine, Stage.Limit) - Method in class io.smallrye.reactive.streams.stages.LimitStageFactory

create(Engine, Stage.Map) - Method in class io.smallrye.reactive.streams.stages.MapStageFactory

create(Engine, Stage.OnComplete) - Method in class io.smallrye.reactive.streams.stages.OnCompleteStageFactory

create(Engine, Stage.OnErrorResume) - Method in class io.smallrye.reactive.streams.stages.OnErrorResumeStageFactory

create(Engine, Stage.OnErrorResumeWith) - Method in class io.smallrye.reactive.streams.stages.OnErrorResumeWithStageFactory

create(Engine, Stage.OnError) - Method in class io.smallrye.reactive.streams.stages.OnErrorStageFactory

create(Engine, Stage.OnTerminate) - Method in class io.smallrye.reactive.streams.stages.OnTerminateStageFactory

create(Engine, Stage.Peek) - Method in class io.smallrye.reactive.streams.stages.PeekStageFactory

create(Engine, Stage.ProcessorStage) - Method in class io.smallrye.reactive.streams.stages.ProcessorStageFactory

create(Engine, Stage.Skip) - Method in class io.smallrye.reactive.streams.stages.SkipStageFactory

create(Engine, Stage.SubscriberStage) - Method in class io.smallrye.reactive.streams.stages.SubscriberStageFactory

create(Engine, Stage.TakeWhile) - Method in class io.smallrye.reactive.streams.stages.TakeWhileStageFactory

D

DefaultSubscriberWithCompletionStage<T,R> - Class in io.smallrye.reactive.streams.utils

DefaultSubscriberWithCompletionStage(Processor<T, T>, CompletionStage<R>) - Constructor for class io.smallrye.reactive.streams.utils.DefaultSubscriberWithCompletionStage

DelegatingSubscriber<O> - Class in io.smallrye.reactive.streams.utils

A subscriber delegating to another subscriber and enforcing that parameters are not null

DelegatingSubscriber(Subscriber<? super O>) - Constructor for class io.smallrye.reactive.streams.utils.DelegatingSubscriber

DistinctStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.Distinct stage.

DistinctStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.DistinctStageFactory

DropWhileStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.DropWhile stage.

DropWhileStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.DropWhileStageFactory

E

emitAtMostOneItem() - Method in class io.smallrye.reactive.converters.microprofile.PublisherBuilderConverter

emitAtMostOneItem() - Method in interface io.smallrye.reactive.converters.ReactiveTypeConverter

emitAtMostOneItem() - Method in class io.smallrye.reactive.converters.reactor.FluxConverter

emitAtMostOneItem() - Method in class io.smallrye.reactive.converters.reactor.MonoConverter

emitAtMostOneItem() - Method in class io.smallrye.reactive.converters.rxjava1.CompletableConverter

emitAtMostOneItem() - Method in class io.smallrye.reactive.converters.rxjava1.ObservableConverter

emitAtMostOneItem() - Method in class io.smallrye.reactive.converters.rxjava1.SingleConverter

emitAtMostOneItem() - Method in class io.smallrye.reactive.converters.rxjava2.CompletableConverter

emitAtMostOneItem() - Method in class io.smallrye.reactive.converters.rxjava2.FlowableConverter

emitAtMostOneItem() - Method in class io.smallrye.reactive.converters.rxjava2.MaybeConverter

emitAtMostOneItem() - Method in class io.smallrye.reactive.converters.rxjava2.ObservableConverter

emitAtMostOneItem() - Method in class io.smallrye.reactive.converters.rxjava2.SingleConverter

emitItems() - Method in class io.smallrye.reactive.converters.microprofile.PublisherBuilderConverter

emitItems() - Method in interface io.smallrye.reactive.converters.ReactiveTypeConverter

emitItems() - Method in class io.smallrye.reactive.converters.reactor.FluxConverter

emitItems() - Method in class io.smallrye.reactive.converters.reactor.MonoConverter

emitItems() - Method in class io.smallrye.reactive.converters.rxjava1.CompletableConverter

emitItems() - Method in class io.smallrye.reactive.converters.rxjava1.ObservableConverter

emitItems() - Method in class io.smallrye.reactive.converters.rxjava1.SingleConverter

emitItems() - Method in class io.smallrye.reactive.converters.rxjava2.CompletableConverter

emitItems() - Method in class io.smallrye.reactive.converters.rxjava2.FlowableConverter

emitItems() - Method in class io.smallrye.reactive.converters.rxjava2.MaybeConverter

emitItems() - Method in class io.smallrye.reactive.converters.rxjava2.ObservableConverter

emitItems() - Method in class io.smallrye.reactive.converters.rxjava2.SingleConverter

EmptySubscription - Class in io.smallrye.reactive.streams.utils

A implementation ignoring everything.

EmptySubscription() - Constructor for class io.smallrye.reactive.streams.utils.EmptySubscription

Engine - Class in io.smallrye.reactive.streams

Engine() - Constructor for class io.smallrye.reactive.streams.Engine

ExecutionModel - Interface in io.smallrye.reactive.streams.spi

F

FailedPublisherStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.Failed stage.

FailedPublisherStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.FailedPublisherStageFactory

FilterStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of Stage.Filter stage.

FilterStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.FilterStageFactory

FindFirstStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.FindFirst stage.

FindFirstStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.FindFirstStageFactory

FlatMapCompletionStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.FlatMapCompletionStage stage.

FlatMapCompletionStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.FlatMapCompletionStageFactory

FlatMapIterableStageFactory - Class in io.smallrye.reactive.streams.stages

FlatMapIterableStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.FlatMapIterableStageFactory

FlatMapStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.FlatMap stage.

FlatMapStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.FlatMapStageFactory

FlowableCollector<T,A,R> - Class in io.smallrye.reactive.streams.utils

Collect elements of the upstream with the help of the Collector'subscription callback functions.

FlowableCollector(Publisher<T>, Collector<T, A, R>) - Constructor for class io.smallrye.reactive.streams.utils.FlowableCollector

FlowableConverter - Class in io.smallrye.reactive.converters.rxjava2

Converter handling the RX Java 2 Flowable type.

FlowableConverter() - Constructor for class io.smallrye.reactive.converters.rxjava2.FlowableConverter

FluxConverter - Class in io.smallrye.reactive.converters.reactor

FluxConverter() - Constructor for class io.smallrye.reactive.converters.reactor.FluxConverter

fromCompletionStage(CompletionStage<X>) - Method in class io.smallrye.reactive.converters.microprofile.PublisherBuilderConverter

fromCompletionStage(CompletionStage<X>) - Method in interface io.smallrye.reactive.converters.ReactiveTypeConverter

Transforms an instance of CompletionStage to an instance of T.

fromCompletionStage(CompletionStage<X>) - Method in class io.smallrye.reactive.converters.reactor.FluxConverter

fromCompletionStage(CompletionStage<X>) - Method in class io.smallrye.reactive.converters.reactor.MonoConverter

fromCompletionStage(CompletionStage) - Method in class io.smallrye.reactive.converters.rxjava1.CompletableConverter

fromCompletionStage(CompletionStage<X>) - Method in class io.smallrye.reactive.converters.rxjava1.ObservableConverter

fromCompletionStage(CompletionStage<X>) - Method in class io.smallrye.reactive.converters.rxjava1.SingleConverter

fromCompletionStage(CompletionStage) - Method in class io.smallrye.reactive.converters.rxjava2.CompletableConverter

fromCompletionStage(CompletionStage<X>) - Method in class io.smallrye.reactive.converters.rxjava2.FlowableConverter

fromCompletionStage(CompletionStage) - Method in class io.smallrye.reactive.converters.rxjava2.MaybeConverter

fromCompletionStage(CompletionStage<X>) - Method in class io.smallrye.reactive.converters.rxjava2.ObservableConverter

fromCompletionStage(CompletionStage<X>) - Method in class io.smallrye.reactive.converters.rxjava2.SingleConverter

fromCompletionStage(CompletionStage<T>, boolean) - Static method in class io.smallrye.reactive.streams.utils.CompletionStageToPublisher

FromCompletionStageFactory - Class in io.smallrye.reactive.streams.stages

FromCompletionStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.FromCompletionStageFactory

FromCompletionStageNullableFactory - Class in io.smallrye.reactive.streams.stages

FromCompletionStageNullableFactory() - Constructor for class io.smallrye.reactive.streams.stages.FromCompletionStageNullableFactory

FromIterableStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.Of stage.

FromIterableStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.FromIterableStageFactory

fromPublisher(Publisher<X>) - Method in class io.smallrye.reactive.converters.microprofile.PublisherBuilderConverter

fromPublisher(Publisher<X>) - Method in interface io.smallrye.reactive.converters.ReactiveTypeConverter

Transforms an instance of T to a Publisher.

fromPublisher(Publisher<X>) - Method in class io.smallrye.reactive.converters.reactor.FluxConverter

fromPublisher(Publisher<X>) - Method in class io.smallrye.reactive.converters.reactor.MonoConverter

fromPublisher(Publisher<X>) - Method in class io.smallrye.reactive.converters.rxjava1.CompletableConverter

fromPublisher(Publisher) - Method in class io.smallrye.reactive.converters.rxjava1.ObservableConverter

fromPublisher(Publisher<X>) - Method in class io.smallrye.reactive.converters.rxjava1.SingleConverter

fromPublisher(Publisher<X>) - Method in class io.smallrye.reactive.converters.rxjava2.CompletableConverter

fromPublisher(Publisher) - Method in class io.smallrye.reactive.converters.rxjava2.FlowableConverter

fromPublisher(Publisher<X>) - Method in class io.smallrye.reactive.converters.rxjava2.MaybeConverter

fromPublisher(Publisher) - Method in class io.smallrye.reactive.converters.rxjava2.ObservableConverter

fromPublisher(Publisher<X>) - Method in class io.smallrye.reactive.converters.rxjava2.SingleConverter

FromPublisherStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.PublisherStage stage.

FromPublisherStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.FromPublisherStageFactory

future() - Method in class io.smallrye.reactive.streams.utils.WrappedSubscriber

G

get() - Method in interface io.smallrye.reactive.streams.operators.PublisherStage

getCompletion() - Method in class io.smallrye.reactive.streams.utils.DefaultSubscriberWithCompletionStage

getEngine() - Method in class io.smallrye.reactive.streams.cdi.ReactiveEngineProvider

getSubscriber() - Method in class io.smallrye.reactive.streams.utils.DefaultSubscriberWithCompletionStage

I

io.smallrye.reactive.converters - package io.smallrye.reactive.converters

io.smallrye.reactive.converters.microprofile - package io.smallrye.reactive.converters.microprofile

io.smallrye.reactive.converters.reactor - package io.smallrye.reactive.converters.reactor

io.smallrye.reactive.converters.rxjava1 - package io.smallrye.reactive.converters.rxjava1

io.smallrye.reactive.converters.rxjava2 - package io.smallrye.reactive.converters.rxjava2

io.smallrye.reactive.streams - package io.smallrye.reactive.streams

io.smallrye.reactive.streams.cdi - package io.smallrye.reactive.streams.cdi

io.smallrye.reactive.streams.operators - package io.smallrye.reactive.streams.operators

io.smallrye.reactive.streams.spi - package io.smallrye.reactive.streams.spi

io.smallrye.reactive.streams.stages - package io.smallrye.reactive.streams.stages

io.smallrye.reactive.streams.utils - package io.smallrye.reactive.streams.utils

io.smallrye.reactive.streams.utils.recovery - package io.smallrye.reactive.streams.utils.recovery

io.smallrye.reactive.streams.vertx - package io.smallrye.reactive.streams.vertx

L

LimitStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.Limit stage.

LimitStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.LimitStageFactory

lookup(Class<T>) - Static method in class io.smallrye.reactive.converters.Registry

lookup(T) - Static method in class io.smallrye.reactive.streams.stages.Stages

M

MapStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.Map stage.

MapStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.MapStageFactory

MaybeConverter - Class in io.smallrye.reactive.converters.rxjava2

Converter handling the RX Java 2 Maybe type.

MaybeConverter() - Constructor for class io.smallrye.reactive.converters.rxjava2.MaybeConverter

MonoConverter - Class in io.smallrye.reactive.converters.reactor

MonoConverter() - Constructor for class io.smallrye.reactive.converters.reactor.MonoConverter

O

ObservableConverter - Class in io.smallrye.reactive.converters.rxjava1

Converter handling the RX Java Observable type.

ObservableConverter() - Constructor for class io.smallrye.reactive.converters.rxjava1.ObservableConverter

ObservableConverter - Class in io.smallrye.reactive.converters.rxjava2

Converter handling the RX Java 2 Observable type.

ObservableConverter() - Constructor for class io.smallrye.reactive.converters.rxjava2.ObservableConverter

onComplete() - Method in class io.smallrye.reactive.streams.utils.CancellationSubscriber

onComplete() - Method in class io.smallrye.reactive.streams.utils.ConnectableProcessor

onComplete() - Method in class io.smallrye.reactive.streams.utils.DelegatingSubscriber

onComplete() - Method in class io.smallrye.reactive.streams.utils.recovery.OnErrorResumeWithSubscriber

onComplete() - Method in class io.smallrye.reactive.streams.utils.recovery.OnErrorReturnSubscriber

onComplete() - Method in class io.smallrye.reactive.streams.utils.WrappedProcessor

onComplete() - Method in class io.smallrye.reactive.streams.utils.WrappedSubscriber

OnCompleteStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.OnComplete stage.

OnCompleteStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.OnCompleteStageFactory

onError(Throwable) - Method in class io.smallrye.reactive.streams.utils.CancellationSubscriber

onError(Throwable) - Method in class io.smallrye.reactive.streams.utils.ConnectableProcessor

onError(Throwable) - Method in class io.smallrye.reactive.streams.utils.DelegatingSubscriber

onError(Throwable) - Method in class io.smallrye.reactive.streams.utils.recovery.OnErrorResumeWithSubscriber

onError(Throwable) - Method in class io.smallrye.reactive.streams.utils.recovery.OnErrorReturnSubscriber

onError(Throwable) - Method in class io.smallrye.reactive.streams.utils.WrappedProcessor

onError(Throwable) - Method in class io.smallrye.reactive.streams.utils.WrappedSubscriber

OnErrorResumeStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.OnErrorResume stage.

OnErrorResumeStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.OnErrorResumeStageFactory

OnErrorResumeWith<T> - Class in io.smallrye.reactive.streams.utils.recovery

OnErrorResumeWith(Flowable<T>, Function<? super Throwable, ? extends Publisher<? extends T>>) - Constructor for class io.smallrye.reactive.streams.utils.recovery.OnErrorResumeWith

OnErrorResumeWithStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.OnErrorResumeWith stage.

OnErrorResumeWithStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.OnErrorResumeWithStageFactory

OnErrorResumeWithSubscriber<T> - Class in io.smallrye.reactive.streams.utils.recovery

OnErrorReturn<T> - Class in io.smallrye.reactive.streams.utils.recovery

OnErrorReturn(Flowable<T>, Function<? super Throwable, ? extends T>) - Constructor for class io.smallrye.reactive.streams.utils.recovery.OnErrorReturn

OnErrorReturnSubscriber<T> - Class in io.smallrye.reactive.streams.utils.recovery

OnErrorStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.OnError stage.

OnErrorStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.OnErrorStageFactory

onNext(T) - Method in class io.smallrye.reactive.streams.utils.CancellationSubscriber

onNext(T) - Method in class io.smallrye.reactive.streams.utils.ConnectableProcessor

onNext(O) - Method in class io.smallrye.reactive.streams.utils.DelegatingSubscriber

onNext(T) - Method in class io.smallrye.reactive.streams.utils.recovery.OnErrorResumeWithSubscriber

onNext(T) - Method in class io.smallrye.reactive.streams.utils.recovery.OnErrorReturnSubscriber

onNext(T) - Method in class io.smallrye.reactive.streams.utils.WrappedProcessor

onNext(T) - Method in class io.smallrye.reactive.streams.utils.WrappedSubscriber

onSubscribe(Subscription) - Method in class io.smallrye.reactive.streams.utils.CancellationSubscriber

onSubscribe(Subscription) - Method in class io.smallrye.reactive.streams.utils.ConnectableProcessor

onSubscribe(Subscription) - Method in class io.smallrye.reactive.streams.utils.DelegatingSubscriber

onSubscribe(Subscription) - Method in class io.smallrye.reactive.streams.utils.recovery.OnErrorResumeWithSubscriber

onSubscribe(Subscription) - Method in class io.smallrye.reactive.streams.utils.WrappedProcessor

onSubscribe(Subscription) - Method in class io.smallrye.reactive.streams.utils.WrappedSubscriber

OnTerminateStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.OnTerminate stage.

OnTerminateStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.OnTerminateStageFactory

Operator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage> - Class in io.smallrye.reactive.streams.operators

P

PeekStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.Peek stage.

PeekStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.PeekStageFactory

ProcessingStage<I,O> - Interface in io.smallrye.reactive.streams.operators

Defines a processing stage - so a stream transformation.

ProcessingStageFactory<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage> - Interface in io.smallrye.reactive.streams.operators

Factory to create ProcessingStage instances.

ProcessorOperator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage> - Class in io.smallrye.reactive.streams.operators

ProcessorOperator(Class<T>, ProcessingStageFactory<T>) - Constructor for class io.smallrye.reactive.streams.operators.ProcessorOperator

ProcessorStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.ProcessorStage stage (via operators).

ProcessorStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.ProcessorStageFactory

PublisherBuilderConverter - Class in io.smallrye.reactive.converters.microprofile

PublisherBuilderConverter() - Constructor for class io.smallrye.reactive.converters.microprofile.PublisherBuilderConverter

PublisherOperator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage> - Class in io.smallrye.reactive.streams.operators

PublisherOperator(Class<T>, PublisherStageFactory<T>) - Constructor for class io.smallrye.reactive.streams.operators.PublisherOperator

PublisherStage<O> - Interface in io.smallrye.reactive.streams.operators

Specialization of the ProcessingStage for data sources (publishers).

PublisherStageFactory<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage> - Interface in io.smallrye.reactive.streams.operators

Factory to create PublisherStage instances.

R

ReactiveEngineProvider - Class in io.smallrye.reactive.streams.cdi

ReactiveEngineProvider() - Constructor for class io.smallrye.reactive.streams.cdi.ReactiveEngineProvider

ReactiveTypeConverter<T> - Interface in io.smallrye.reactive.converters

Converts a specific reactive types from and to CompletionStage and Publisher.

register(ReactiveTypeConverter...) - Static method in class io.smallrye.reactive.converters.Registry

Registry - Class in io.smallrye.reactive.converters

request(long) - Method in class io.smallrye.reactive.streams.utils.EmptySubscription

request(long) - Method in class io.smallrye.reactive.streams.utils.WrappedSubscription

requireAtLeastOneItem() - Method in interface io.smallrye.reactive.converters.ReactiveTypeConverter

requireAtLeastOneItem() - Method in class io.smallrye.reactive.converters.rxjava1.SingleConverter

requireAtLeastOneItem() - Method in class io.smallrye.reactive.converters.rxjava2.SingleConverter

S

SingleConverter - Class in io.smallrye.reactive.converters.rxjava1

Converter handling the RX Java 1 Single type.

SingleConverter() - Constructor for class io.smallrye.reactive.converters.rxjava1.SingleConverter

SingleConverter - Class in io.smallrye.reactive.converters.rxjava2

Converter handling the RX Java 2 Single type.

SingleConverter() - Constructor for class io.smallrye.reactive.converters.rxjava2.SingleConverter

SkipStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.Skip stage.

SkipStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.SkipStageFactory

source() - Method in class io.smallrye.reactive.streams.utils.recovery.OnErrorResumeWith

source() - Method in class io.smallrye.reactive.streams.utils.recovery.OnErrorReturn

Stages - Class in io.smallrye.reactive.streams.stages

Allows looking for the Operator for a given Stage.

subscribe(Subscriber<? super T>) - Method in class io.smallrye.reactive.streams.utils.CancellablePublisher

subscribe(Subscriber<? super T>) - Method in class io.smallrye.reactive.streams.utils.ConnectableProcessor

subscribe(Subscriber<? super O>) - Method in class io.smallrye.reactive.streams.utils.CouplingProcessor

subscribe(Subscriber<? super T>) - Method in class io.smallrye.reactive.streams.utils.WrappedProcessor

subscribeActual(Subscriber<? super R>) - Method in class io.smallrye.reactive.streams.utils.FlowableCollector

subscribeActual(Subscriber<? super T>) - Method in class io.smallrye.reactive.streams.utils.recovery.OnErrorResumeWith

subscribeActual(Subscriber<? super T>) - Method in class io.smallrye.reactive.streams.utils.recovery.OnErrorReturn

SubscriberStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.SubscriberStage stage.

SubscriberStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.SubscriberStageFactory

supportNullValue() - Method in class io.smallrye.reactive.converters.microprofile.PublisherBuilderConverter

supportNullValue() - Method in interface io.smallrye.reactive.converters.ReactiveTypeConverter

supportNullValue() - Method in class io.smallrye.reactive.converters.reactor.FluxConverter

supportNullValue() - Method in class io.smallrye.reactive.converters.reactor.MonoConverter

supportNullValue() - Method in class io.smallrye.reactive.converters.rxjava1.CompletableConverter

supportNullValue() - Method in class io.smallrye.reactive.converters.rxjava1.ObservableConverter

supportNullValue() - Method in class io.smallrye.reactive.converters.rxjava1.SingleConverter

supportNullValue() - Method in class io.smallrye.reactive.converters.rxjava2.CompletableConverter

supportNullValue() - Method in class io.smallrye.reactive.converters.rxjava2.FlowableConverter

supportNullValue() - Method in class io.smallrye.reactive.converters.rxjava2.MaybeConverter

supportNullValue() - Method in class io.smallrye.reactive.converters.rxjava2.ObservableConverter

supportNullValue() - Method in class io.smallrye.reactive.converters.rxjava2.SingleConverter

T

TakeWhileStageFactory - Class in io.smallrye.reactive.streams.stages

Implementation of the Stage.TakeWhile stage.

TakeWhileStageFactory() - Constructor for class io.smallrye.reactive.streams.stages.TakeWhileStageFactory

TerminalOperator<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage> - Class in io.smallrye.reactive.streams.operators

TerminalOperator(Class<T>, TerminalStageFactory<T>) - Constructor for class io.smallrye.reactive.streams.operators.TerminalOperator

TerminalStage<I,O> - Interface in io.smallrye.reactive.streams.operators

Defines a terminal stage - so a stream subscription and observation.

TerminalStageFactory<T extends org.eclipse.microprofile.reactive.streams.operators.spi.Stage> - Interface in io.smallrye.reactive.streams.operators

Factory to create TerminalStage instances.

test(Stage) - Method in class io.smallrye.reactive.streams.operators.Operator

toCompletionStage(PublisherBuilder) - Method in class io.smallrye.reactive.converters.microprofile.PublisherBuilderConverter

toCompletionStage(T) - Method in interface io.smallrye.reactive.converters.ReactiveTypeConverter

Transforms an instance of T to a CompletionStage completed with a potential value.

toCompletionStage(Flux) - Method in class io.smallrye.reactive.converters.reactor.FluxConverter

toCompletionStage(Mono) - Method in class io.smallrye.reactive.converters.reactor.MonoConverter

toCompletionStage(Completable) - Method in class io.smallrye.reactive.converters.rxjava1.CompletableConverter

toCompletionStage(Observable) - Method in class io.smallrye.reactive.converters.rxjava1.ObservableConverter

toCompletionStage(Single) - Method in class io.smallrye.reactive.converters.rxjava1.SingleConverter

toCompletionStage(Completable) - Method in class io.smallrye.reactive.converters.rxjava2.CompletableConverter

toCompletionStage(Flowable) - Method in class io.smallrye.reactive.converters.rxjava2.FlowableConverter

toCompletionStage(Maybe) - Method in class io.smallrye.reactive.converters.rxjava2.MaybeConverter

toCompletionStage(Observable) - Method in class io.smallrye.reactive.converters.rxjava2.ObservableConverter

toCompletionStage(Single) - Method in class io.smallrye.reactive.converters.rxjava2.SingleConverter

toRSPublisher(PublisherBuilder) - Method in class io.smallrye.reactive.converters.microprofile.PublisherBuilderConverter

toRSPublisher(T) - Method in interface io.smallrye.reactive.converters.ReactiveTypeConverter

Transforms an instance of T to a Publisher.

toRSPublisher(Flux) - Method in class io.smallrye.reactive.converters.reactor.FluxConverter

toRSPublisher(Mono) - Method in class io.smallrye.reactive.converters.reactor.MonoConverter

toRSPublisher(Completable) - Method in class io.smallrye.reactive.converters.rxjava1.CompletableConverter

toRSPublisher(Observable) - Method in class io.smallrye.reactive.converters.rxjava1.ObservableConverter

toRSPublisher(Single) - Method in class io.smallrye.reactive.converters.rxjava1.SingleConverter

toRSPublisher(Completable) - Method in class io.smallrye.reactive.converters.rxjava2.CompletableConverter

toRSPublisher(Flowable) - Method in class io.smallrye.reactive.converters.rxjava2.FlowableConverter

toRSPublisher(Maybe) - Method in class io.smallrye.reactive.converters.rxjava2.MaybeConverter

toRSPublisher(Observable) - Method in class io.smallrye.reactive.converters.rxjava2.ObservableConverter

toRSPublisher(Single) - Method in class io.smallrye.reactive.converters.rxjava2.SingleConverter

Transformer - Class in io.smallrye.reactive.streams.spi

type() - Method in class io.smallrye.reactive.converters.microprofile.PublisherBuilderConverter

type() - Method in interface io.smallrye.reactive.converters.ReactiveTypeConverter

type() - Method in class io.smallrye.reactive.converters.reactor.FluxConverter

type() - Method in class io.smallrye.reactive.converters.reactor.MonoConverter

type() - Method in class io.smallrye.reactive.converters.rxjava1.CompletableConverter

type() - Method in class io.smallrye.reactive.converters.rxjava1.ObservableConverter

type() - Method in class io.smallrye.reactive.converters.rxjava1.SingleConverter

type() - Method in class io.smallrye.reactive.converters.rxjava2.CompletableConverter

type() - Method in class io.smallrye.reactive.converters.rxjava2.FlowableConverter

type() - Method in class io.smallrye.reactive.converters.rxjava2.MaybeConverter

type() - Method in class io.smallrye.reactive.converters.rxjava2.ObservableConverter

type() - Method in class io.smallrye.reactive.converters.rxjava2.SingleConverter

V

VertxExecutionModel - Class in io.smallrye.reactive.streams.vertx

An implementation of ExecutionModel enforcing the Vert.x execution model.

VertxExecutionModel() - Constructor for class io.smallrye.reactive.streams.vertx.VertxExecutionModel

W

WrappedProcessor<T> - Class in io.smallrye.reactive.streams.utils

Processor wrapping a publisher and subscriber, and connect them

WrappedProcessor(Subscriber<T>, Publisher<T>) - Constructor for class io.smallrye.reactive.streams.utils.WrappedProcessor

WrappedSubscriber<T> - Class in io.smallrye.reactive.streams.utils

WrappedSubscriber(Subscriber<T>) - Constructor for class io.smallrye.reactive.streams.utils.WrappedSubscriber

WrappedSubscription - Class in io.smallrye.reactive.streams.utils

A B C D E F G I L M O P R S T V W