A RxJava extension that enables the scheduler to run code in other threads of the application and provides the transfer of results from other threads to the main thread for aggregation and interaction with the user interface.