khunzohn

public void getUser(String userId) {
  getView().showLoading(“fetching user…”);
  
  Subscription sub = userRepository.getUser(userId) 
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidScheduler.mainThread())
    .subscribe(user -> {
        getView().stopLoading();
        getView().render(user);
    },e->{

khunzohn

interface MovieService {

    @GET("movie/now_playing")
    suspend fun getUpcomingMovies(@Query("api_key") apiKey: String): Response<MovieResponse>
}

khunzohn

interface MovieService {
    @GET("movie/now_playing")
    suspend fun getUpcomingMovies(@Query("api_key") apiKey: String): Response<MovieResponse>
}

khunzohn

viewModelScope.launch {
    try {
        val movies = movieService.getUpcomingMovies()
    } catch (e: Exception) {
        //...
    }
}

khunzohn

data class MovieResponse(
    val errorCode: Int?,
    val errorMessage: String?,
    val results: List<MovieData>
)

khunzohn

class FetchMacsUseCase constructor(
    private val productRepository: ProductRepository
) {
    fun run(): Observable<MacsPartialState> {
        return productRepository.fetchMacs()
            .toObservable()
            .map { MacsPartialState.MacsResult(it) }
            .cast(MacsPartialState::class.java)
            .startWith(MacsPartialState.LoadingMacs)
            .onErrorReturn { error -> MacsPartialState.LoadMacsError(error) }