RxJava Blogs

RxJava Subject - Publish, Replay, Behavior, and Async

RxJava Subject - Publish, Replay, Behavior, and Async

A Subject in RxJava acts as both an Observer and an Observable. Publish, Replay, Behavior, and Async Subjects differ in which items a new subscriber gets.

Pagination In RecyclerView Using RxJava Operators

Pagination In RecyclerView Using RxJava Operators

We can implement pagination in RecyclerView using RxJava operators like PublishProcessor, concatMap, and onBackpressureDrop, to load more data as we scroll.

RxJava Operator Map vs FlatMap

RxJava Operator Map vs FlatMap

In RxJava, Map transforms each item emitted by an Observable by applying a function, whereas FlatMap transforms each item into an Observable.

RxJava Merge Operator

RxJava Merge Operator

The Merge operator of RxJava combines multiple Observables into one by merging their emissions. Unlike Concat, it does not maintain the order.

RxJava Concat Operator

RxJava Concat Operator

The Concat operator of RxJava emits the items of two or more observables one after another, without interleaving them, so the order is maintained.

dispose vs clear CompositeDisposable RxJava

dispose vs clear CompositeDisposable RxJava

In RxJava, clear() removes all the disposables but can accept new ones, whereas dispose() removes all of them and does not accept any new disposable.

RxJava Interval Operator

RxJava Interval Operator

The Interval operator of RxJava creates an Observable that emits a sequence of integers spaced by a given time interval. We use it to repeat a task.

RxJava Create and fromCallable Operator

RxJava Create and fromCallable Operator

The Create operator of RxJava can emit many values one by one and then complete, whereas fromCallable emits only one item. Let's learn when to use which one.

RxJava Defer Operator

RxJava Defer Operator

The Defer operator of RxJava does not create the Observable until an observer subscribes, and it creates a fresh Observable for each observer.

RxJava Zip Operator

RxJava Zip Operator

The Zip operator of RxJava combines the emissions of multiple Observables together using a function, so that we get the results from all of them at a time.

Types Of Observables In RxJava

Types Of Observables In RxJava

The types of Observables in RxJava are Observable, Flowable, Single, Maybe, and Completable. Each one fits a different use case, based on what it emits.

Instant Search Using RxJava Operators

Instant Search Using RxJava Operators

We can build instant search in Android using RxJava operators like debounce, filter, distinctUntilChanged, and switchMap, to avoid extra network calls.

RxJava Tutorial

RxJava Tutorial

RxJava is a library for reactive programming, where the consumer reacts to data as it comes in. Here are all the resources to learn RxJava in one place.