Package hu.akarnokd.rxjava3.operators
Utility methods for uncommon, custom, special and exotic operators for RxJava flows
in the form of transformers and converters:
-
Interface Summary Interface Description BasicEmitter<T> Abstraction over a Subscriber.FlowableAsyncEmitter<T> Provides an API on top of theEmittersignals that allow setting and replacing aCancellableresource 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 ofCompletableConverters, useCompletable.to(CompletableConverter)to apply the operators to an existing sequence.CompletableTransformers Additional operators in the form ofCompletableTransformer, useCompletable.compose(CompletableTransformer)to apply the operators to an existing sequence.Flowables Utility class to create Flowable sources.FlowableTransformers Additional operators in the form ofFlowableTransformer, useFlowable.compose(FlowableTransformer)to apply the operators to an existing sequence.Maybes Additional operators in the form ofMaybeConverters, useMaybe.to(MaybeConverter)to apply the operators to an existing sequence.MaybeTransformers Additional operators in the form ofMaybeTransformer, useMaybe.compose(MaybeTransformer)to apply the operators to an existing sequence.Observables Utility class to create Observable sources.ObservableTransformers Additional operators in the form ofObservableTransformer, useObservable.compose(ObservableTransformer)to apply the operators to an existing sequence.Singles Additional operators in the form ofSingleConverters, useSingle.to(SingleConverter)to apply the operators to an existing sequence.SingleTransformers Additional operators in the form ofSingleTransformer, useSingle.compose(SingleTransformer)to apply the operators to an existing sequence. -
Enum Summary Enum Description ExpandStrategy Represents the strategies for recursive expansion with theexpand()operator.