Rx Extensions added

Author: MateuszWolkowicz

androidextensions/build.gradle

@@ -28,13 +28,22 @@ android {
 
 dependencies {
     implementation fileTree(dir: 'libs', include: ['*.jar'])
-
+    implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk7:$kotlin_version"
     implementation 'androidx.appcompat:appcompat:1.0.2'
+
+    // Reactive extensions
+    implementation "io.reactivex.rxjava2:rxjava:$rx_java"
+    implementation "io.reactivex.rxjava2:rxandroid:$rx_java_android"
+
+    // KTX
+    implementation "androidx.core:core-ktx:$android_core_ktx"
+    implementation "androidx.lifecycle:lifecycle-reactivestreams-ktx:$lifecycle_reactivestreams_ktx"
+    implementation "androidx.collection:collection-ktx:$collection_ktx"
+    implementation "androidx.fragment:fragment-ktx:$fragment_ktx"
+
     testImplementation 'junit:junit:4.12'
     androidTestImplementation 'androidx.test:runner:1.2.0'
     androidTestImplementation 'androidx.test.espresso:espresso-core:3.2.0'
-    compile "androidx.core:core-ktx:+"
-    implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk7:$kotlin_version"
 }
 repositories {
     mavenCentral()

androidextensions/src/main/java/com/wolkowiczmateusz/androidextensions/RxExtensions.kt

@@ -0,0 +1,15 @@
+package com.wolkowiczmateusz.androidextensions
+
+import androidx.lifecycle.LiveData
+import io.reactivex.BackpressureStrategy
+import io.reactivex.Observable
+import io.reactivex.Single
+import androidx.lifecycle.LiveDataReactiveStreams
+
+fun <T> Observable<T>.toLiveData(backPressureStrategy: BackpressureStrategy = BackpressureStrategy.BUFFER): LiveData<T> {
+    return LiveDataReactiveStreams.fromPublisher(this.toFlowable(backPressureStrategy))
+}
+
+fun <T> Single<T>.toLiveData(): LiveData<T> {
+    return LiveDataReactiveStreams.fromPublisher(this.toFlowable()) // toFlowable 230ms
+}

app/build.gradle

@@ -27,7 +27,7 @@ dependencies {
     implementation fileTree(dir: 'libs', include: ['*.jar'])
     implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk7:$kotlin_version"
     implementation 'androidx.appcompat:appcompat:1.0.2'
-    implementation 'androidx.core:core-ktx:1.0.2'
+    implementation "androidx.core:core-ktx:$android_core_ktx"
     testImplementation 'junit:junit:4.12'
     androidTestImplementation 'androidx.test:runner:1.2.0'
     androidTestImplementation 'androidx.test.espresso:espresso-core:3.2.0'

build.gradle

@@ -1,7 +1,15 @@
 // Top-level build file where you can add configuration options common to all sub-projects/modules.
 
 buildscript {
-    ext.kotlin_version = '1.3.41'
+    ext {
+        kotlin_version = '1.3.41'
+        rx_java = '2.2.9'
+        rx_java_android = '2.1.1'
+        android_core_ktx = '1.0.2'
+        collection_ktx = '1.0.0'
+        fragment_ktx = '1.0.0'
+        lifecycle_reactivestreams_ktx = '2.1.0-rc01'
+    }
     repositories {
         google()
         jcenter()