RxJavaErrorHandling1.kt

class RxJavaTest {

  companion object {
    private const val USER_ID = "USER_ID"
    private const val NAME = "John Doe"
    private const val AGE = 20
  }

  @Test
  fun getUser() {
    getUserId()
      .flatMap(this::getUser)
      .flatMap(this::saveUser)
      .subscribe(::println)
  }

  private fun getUserId(): Observable<String> {
    return Observable.fromCallable {
      USER_ID
    }
  }

  private fun getUser(id: String): Observable<User> {
    val user = User(
      id = id,
      name = NAME,
      age =  AGE
    )
    return Observable.fromCallable { user }
  }
  
  private fun saveUser(user: User): Observable<User> {
    // Perform save user data operations
    return Observable.fromCallable { user }
  }
  
  
}

data class User(
    val id: String,
    val name: String,
    val age: Int
)