RxJava Migration

Overview

Migrate RxJava code to Kotlin coroutines and flows incrementally. Simple cases map directly. Complex cases require a strategy and user input before any code is written.

Only invoke this skill when the user explicitly asks to migrate RxJava code.

Step 1: Complexity Assessment

Before writing a single line of migrated code, classify what you are looking at:

Simple — apply type and operator mapping directly:

• Single RxJava type (Single, Observable, Completable, Maybe)
• ≤3 operators in the chain
• Standard schedulers (Schedulers.io(), AndroidSchedulers.mainThread())
• No complex error recovery (retryWhen, onErrorResumeNext with fallback flows)
• No hot observables with backpressure (Flowable)