Package hu.akarnokd.rxjava3.operators

Utility methods for uncommon, custom, special and exotic operators for RxJava flows in the form of transformers and converters:

• FlowableTransformers, Flowables,
• ObservableTransformers, Observables,
• MaybeTransformers, Maybes,
• SingleTransformers, Singles,
• CompletableTransformers and Completables.

Interface Summary

Interface	Description
BasicEmitter<T>	Abstraction over a Subscriber.
FlowableAsyncEmitter<T>	Provides an API on top of the Emitter signals that allow setting and replacing a Cancellable resource to be cancelled when the associated flow is cancelled.
PartialCollectEmitter<T,I,A,R>	Provides callbacks and methods to support the partial collect operator: access to cached elements, save and retrieve an input index and accumulator and produce the output instance.

Class Summary

Class	Description
BasicMergeSubscription<T>	Subscription coordinator that merges items from a fixed set of source Publishers by picking the smallest available next item from them based on a Comparator.
Completables	Additional operators in the form of CompletableConverters, use Completable.to(CompletableConverter) to apply the operators to an existing sequence.
CompletableTransformers	Additional operators in the form of CompletableTransformer, use Completable.compose(CompletableTransformer) to apply the operators to an existing sequence.
Flowables	Utility class to create Flowable sources.
FlowableTransformers	Additional operators in the form of FlowableTransformer, use Flowable.compose(FlowableTransformer) to apply the operators to an existing sequence.
Maybes	Additional operators in the form of MaybeConverters, use Maybe.to(MaybeConverter) to apply the operators to an existing sequence.
MaybeTransformers	Additional operators in the form of MaybeTransformer, use Maybe.compose(MaybeTransformer) to apply the operators to an existing sequence.
Observables	Utility class to create Observable sources.
ObservableTransformers	Additional operators in the form of ObservableTransformer, use Observable.compose(ObservableTransformer) to apply the operators to an existing sequence.
Singles	Additional operators in the form of SingleConverters, use Single.to(SingleConverter) to apply the operators to an existing sequence.
SingleTransformers	Additional operators in the form of SingleTransformer, use Single.compose(SingleTransformer) to apply the operators to an existing sequence.

Enum Summary

Enum	Description
ExpandStrategy	Represents the strategies for recursive expansion with the expand() operator.