RxJava | RxAndroid - III

Learn RxJava schedulers: io for background work, computation for cpu tasks, and Android schedulers to move results to the user interface, with single, trampoline, and new thread patterns.

Learn to implement RxJava and RxAndroid schedulers, switch tasks between the main thread and background threads, and update the UI using upstream and downstream flows with reactive extensions.

Learn how cold observables in RxJava work: items emit only after subscription, and each observer gets its own item sequence. See real‑world examples like Retrofit and run queries.

Learn how a cold observable emits values only when subscribed, returning a user list each time, unlike a hot observable that emits independently.

Explore how hot observables differ from cold observables, showing a single emission source where subscribers may miss prior values, emphasizing time-sensitive event streams.

Learn how a connectable observable becomes a hot observable by delaying emission until a connection is established; subscribe before connect to see values, otherwise values may be missed.

Learn how connectable observable uses multicasting to share a single source across multiple observers, emitting only after connect(), and delivering values to all observers at once.

Explore the RxJava subject, a bridge that acts as both observer and observable, and learn the four types: subject, publish subject, and replace subject, with practical implementations.

Learn how AsyncSubject in RxJava emits only the last value after completion, delivering it to all subscribers; if an error occurs, it emits no items and passes the error.

Explore AsyncSubject in RxJava by building a subject that acts as both observer and observable; emit values with onNext, trigger onComplete to deliver the last item to subscribers.

Explore how BehaviorSubject emits the most recent item to new subscribers and continues broadcasting subsequent values, demonstrated with a radio value example.

Implement a BehaviorSubject in RxJava RxAndroid, using a subject as an observer, subscribing to an observable, and emitting the most recent value to new subscribers.

Explore how PublishSubject in RxJava RxAndroid emits items only after subscription, risking missed events if created before observers subscribe, and how errors stop emissions for subsequent observers.

Explore how PublishSubject in RxJava RxAndroid delivers items only from the moment of subscription, skipping prior emissions, and ensures new onNext values reach current subscribers.

explains replay subject in rxjava rxandroid: emits all items to any observer regardless of subscription time, includes time-span variants, and warns about onNext usage to avoid ambiguity.

Learn how ReplaySubject in RxJava RxAndroid replays all emitted items to every observer, regardless of subscription time, ensuring no value is missed.