All Packages

Package Summary

Package	Description
hu.akarnokd.rxjava3.async	Utility methods to jumpstart a reactive sequence via AsyncFlowable and AsyncObservable; port of the RxJavaAsyncUtil library.
hu.akarnokd.rxjava3.basetypes	Proof-of-concept backpressure enabled 0..1 element reactive types: Solo, Perhaps and Nono.
hu.akarnokd.rxjava3.consumers	Utility methods to create special consumer types, such as auto-release consumers via FlowableConsumers, ObservableConsumers, MaybeConsumers, SingleConsumers and CompletableConsumers.
hu.akarnokd.rxjava3.debug	Debugging support to remember where operators have been created in the code via RxJavaPlugins' assembly hooks, enabled via RxJavaAssemblyTracking.
hu.akarnokd.rxjava3.debug.multihook	Proof of concept RxJavaPlugins hook implementation for handling multiple hooks to the onSchedule callback via OnScheduleMultiHandlerManager.
hu.akarnokd.rxjava3.debug.validator	Protocol validation support via RxJavaPlugins hook implementations enalbed via RxJavaProtocolValidator.
hu.akarnokd.rxjava3.expr	Utility methods for computational expressions and statements via StatementFlowable and StatementObservable; a port of the RxJavaComputationExpression library.
hu.akarnokd.rxjava3.functions	Functional interface definitions for Consumers with 3..9 arguments and Functions without the throws Exception clause in their definition.
hu.akarnokd.rxjava3.joins	Utility methods for join patterns (more generic way than combineLatest) via JoinObservable wrapper and the and/then/when vocabulary; a port of the RxJavaJoins library.
hu.akarnokd.rxjava3.math	Utility methods for aggregating and reducing flows with numeric content via MathFlowable and MathObservable; a port of the RxJavaMath library.
hu.akarnokd.rxjava3.operators	Utility methods for uncommon, custom, special and exotic operators for RxJava flows in the form of transformers and converters.
hu.akarnokd.rxjava3.parallel	Utility methods for parallel aggregation and reduction for ParallelFlowables via ParallelTransformers.
hu.akarnokd.rxjava3.processors	Special processors such as DispatchWorkProcessor and generic utilities for FlowableProcessors via FlowableProcessors methods.
hu.akarnokd.rxjava3.schedulers	Special scheduler implementations, such as BlockingScheduler, ParallelScheduler and SharedScheduler.
hu.akarnokd.rxjava3.string	Utility methods working with strings and character sequences via StringFlowable and StringObservable; a partial port of the RxJavaString library.
hu.akarnokd.rxjava3.subjects	Special subjects such as UnicastWorkSubject, DispatchWorkSubject and generic utilities for Subjects via Subjects methods.
hu.akarnokd.rxjava3.util	Utility classes and methods supporting the other utilities in this library.