Add: RxJava2 and RxAndroid

app/build.gradle

@@ -48,6 +48,11 @@ dependencies {
     kapt "com.google.dagger:dagger-android-processor:$dagger_version"
     kapt "com.google.dagger:dagger-compiler:$dagger_version"
 
+    // RxJava and RxAndroid
+    implementation "io.reactivex.rxjava2:rxjava:$rxjava_version"
+    implementation "io.reactivex.rxjava2:rxandroid:$rxandroid_version"
+    implementation "com.jakewharton.retrofit:retrofit2-rxjava2-adapter:$retrofit_adapter"
+
     testImplementation 'junit:junit:4.12'
     androidTestImplementation 'com.android.support.test:runner:1.0.2'
     androidTestImplementation 'com.android.support.test.espresso:espresso-core:3.0.2'

app/src/main/java/com/android/nikhil/worldnow/di/module/AppModule.kt

@@ -1,6 +1,7 @@
 package com.android.nikhil.worldnow.di.module
 
 import com.android.nikhil.worldnow.network.NewsInterface
+import com.jakewharton.retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory
 import dagger.Module
 import dagger.Provides
 import retrofit2.Retrofit
@@ -16,6 +17,7 @@ class AppModule {
     return Retrofit.Builder()
         .baseUrl("https://content.guardianapis.com")
         .addConverterFactory(GsonConverterFactory.create())
+        .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
         .build()
   }
 

app/src/main/java/com/android/nikhil/worldnow/network/NewsInterface.kt

@@ -1,13 +1,14 @@
 package com.android.nikhil.worldnow.network
 
 import com.android.nikhil.worldnow.utils.MainResponse
+import io.reactivex.Observable
 import retrofit2.http.GET
 import retrofit2.Call
 import retrofit2.http.Query
 
 interface NewsInterface {
 
     @GET("search")
-    fun getNews(@Query("api-key") apiKey: String): Call<MainResponse>
+    fun getNews(@Query("api-key") apiKey: String): Observable<MainResponse>
 
 }

app/src/main/java/com/android/nikhil/worldnow/ui/news/NewsViewModal.kt

@@ -7,6 +7,8 @@ import com.android.nikhil.worldnow.BuildConfig
 import com.android.nikhil.worldnow.network.NewsInterface
 import com.android.nikhil.worldnow.utils.MainResponse
 import com.android.nikhil.worldnow.utils.Result
+import io.reactivex.android.schedulers.AndroidSchedulers
+import io.reactivex.schedulers.Schedulers
 import retrofit2.Call
 import retrofit2.Callback
 import javax.inject.Inject
@@ -16,20 +18,13 @@ class NewsViewModal @Inject constructor(): ViewModel() {
     private var newsLiveData = MutableLiveData<ArrayList<Result>>()
     @Inject lateinit var newsApi: NewsInterface
 
-    fun getNewsData(): MutableLiveData<ArrayList<Result>> = newsLiveData
-
     fun getNews() {
-        val callNews = newsApi.getNews(BuildConfig.ApiKey)
-        callNews.enqueue(object: Callback<MainResponse> {
-            override fun onResponse(call: Call<MainResponse>?, mainResponse: retrofit2.Response<MainResponse>?) {
-                val newsResponse = mainResponse?.body()
-                val body = newsResponse?.response
-                if (body?.results != null) newsLiveData.postValue(body.results)
-                else Log.d("", "results are null")
-            }
-            override fun onFailure(call: Call<MainResponse>?, t: Throwable?) {
-                Log.d("", t?.localizedMessage)
-            }
-        })
+        newsApi.getNews(BuildConfig.ApiKey)
+            .subscribeOn(Schedulers.newThread())
+            .observeOn(AndroidSchedulers.mainThread())
+            .map { mainRes -> mainRes.response.results }
+            .subscribe({ value -> newsLiveData.postValue(value) }, { e -> e.printStackTrace() })
     }
+
+  fun getNewsData() = newsLiveData
 }

build.gradle

@@ -29,6 +29,9 @@ ext {
     gson_convertor_version = "2.4.0"
     arch_lifecycle_version = "1.1.1"
     dagger_version = "2.16"
+    rxjava_version = "2.2.1"
+    rxandroid_version = "2.1.0"
+    retrofit_adapter = "1.0.0"
 }
 
 task clean(type: Delete) {