Merge pull request #3 from eadm/domain-rx-1.0.0

add domain rx

Author: eadm

README.md

@@ -47,6 +47,17 @@ dependencies {
 }
 ```
 
+### domain-rx
+[ ![Download](https://api.bintray.com/packages/eadm/ru.nobird.android/ru.nobird.android.domain/images/download.svg) ](https://bintray.com/eadm/ru.nobird.android/ru.nobird.android.domain/_latestVersion)
+
+Расширения для работы с RxJava
+
+```groovy
+dependencies {
+    implementation 'ru.nobird.android.domain:rx:x.y.z'
+}
+```
+
 ### presentation-base
 [ ![Download](https://api.bintray.com/packages/eadm/ru.nobird.android/ru.nobird.android.presentation/images/download.svg) ](https://bintray.com/eadm/ru.nobird.android/ru.nobird.android.presentation/_latestVersion)
 

dependencies.gradle

@@ -7,6 +7,7 @@ ext.versions = [
         viewInjectionName    : '1.0.0',
 
         presentationBaseName : '1.1.1',
+        domainRxName         : '1.0.0',
 
         minSdk               : 16,
         targetSdk            : 29,

domain-rx/.gitignore

@@ -0,0 +1 @@
+/build

domain-rx/build.gradle

@@ -0,0 +1,58 @@
+apply plugin: 'com.android.library'
+apply plugin: 'kotlin-android'
+
+apply plugin: 'com.github.dcendents.android-maven'
+apply plugin: 'com.jfrog.bintray'
+
+android {
+    compileSdkVersion versions.compileSdk
+    buildToolsVersion versions.buildTools
+
+    defaultConfig {
+        minSdkVersion versions.minSdk
+        targetSdkVersion versions.targetSdk
+        versionCode versions.code
+        versionName versions.domainRxName
+
+        testInstrumentationRunner "android.support.test.runner.AndroidJUnitRunner"
+
+    }
+
+    buildTypes {
+        release {
+            minifyEnabled false
+            proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
+        }
+    }
+}
+
+dependencies {
+    implementation libraries.kotlin
+    implementation libraries.rxJava2
+}
+
+ext {
+    bintrayRepo = 'ru.nobird.android'
+    bintrayName = 'ru.nobird.android.domain'
+
+    publishedGroupId = 'ru.nobird.android.domain'
+    libraryName = 'Domain-Rx'
+    artifact = 'rx'
+
+    libraryDescription = 'Collection of rx domain extensions'
+
+    siteUrl = 'https://github.com/eadm/AndroidKit/domain-rx'
+    gitUrl = 'https://github.com/eadm/AndroidKit/domain-rx'
+
+    libraryVersion = versions.domainRxName
+
+    developerId = 'eadm'
+    developerName = 'Ruslan Davletshin'
+    developerEmail = '[email protected]'
+
+    licenseName = 'The Apache Software License, Version 2.0'
+    licenseUrl = 'http://www.apache.org/licenses/LICENSE-2.0.txt'
+    allLicenses = ["Apache-2.0"]
+}
+
+apply from: "../bintray.gradle"

domain-rx/consumer-rules.pro

@@ -0,0 +1,21 @@
+# Add project specific ProGuard rules here.
+# You can control the set of applied configuration files using the
+# proguardFiles setting in build.gradle.
+#
+# For more details, see
+#   http://developer.android.com/guide/developing/tools/proguard.html
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+#   public *;
+#}
+
+# Uncomment this to preserve the line number information for
+# debugging stack traces.
+#-keepattributes SourceFile,LineNumberTable
+
+# If you keep the line number information, uncomment this to
+# hide the original source file name.
+#-renamesourcefileattribute SourceFile

domain-rx/proguard-rules.pro

@@ -0,0 +1,24 @@
+package ru.nobird.android.domain.rx
+
+import androidx.test.platform.app.InstrumentationRegistry
+import androidx.test.ext.junit.runners.AndroidJUnit4
+
+import org.junit.Test
+import org.junit.runner.RunWith
+
+import org.junit.Assert.*
+
+/**
+ * Instrumented test, which will execute on an Android device.
+ *
+ * See [testing documentation](http://d.android.com/tools/testing).
+ */
+@RunWith(AndroidJUnit4::class)
+class ExampleInstrumentedTest {
+    @Test
+    fun useAppContext() {
+        // Context of the app under test.
+        val appContext = InstrumentationRegistry.getInstrumentation().targetContext
+        assertEquals("ru.nobird.android.domain.rx.test", appContext.packageName)
+    }
+}

domain-rx/src/androidTest/java/ru/nobird/android/domain/rx/ExampleInstrumentedTest.kt

@@ -0,0 +1,5 @@
+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+    package="ru.nobird.android.domain.rx">
+
+    /
+</manifest>

domain-rx/src/main/AndroidManifest.xml

@@ -0,0 +1,60 @@
+package ru.nobird.android.domain.rx
+
+import io.reactivex.Completable
+import io.reactivex.Maybe
+import io.reactivex.Observable
+import io.reactivex.Single
+
+inline fun <T> Maybe<T>.doCompletableOnSuccess(crossinline completableSource: (T) -> Completable): Maybe<T> =
+    flatMap { completableSource(it).andThen(Maybe.just(it)) }
+
+inline fun <T> Single<T>.doCompletableOnSuccess(crossinline completableSource: (T) -> Completable): Single<T> =
+    flatMap { completableSource(it).andThen(Single.just(it)) }
+
+/**
+ * Check list for size or return error
+ */
+fun <T> Single<List<T>>.requireSize(size: Int): Single<List<T>> =
+    flatMap { list ->
+        list.takeIf { it.size == size }
+            ?.let { Single.just(it) }
+            ?: Single.error(IllegalStateException("Expected list size = $size, actual = ${list.size}"))
+    }
+
+/**
+ * Empty on error stub in order to suppress errors
+ */
+val emptyOnErrorStub: (Throwable) -> Unit = {}
+
+/**
+ * Filters observable according to [predicateSource] predicate
+ */
+fun <T> Observable<T>.filterSingle(predicateSource: (T) -> Single<Boolean>): Observable<T> =
+    flatMap { item ->
+        predicateSource(item)
+            .toObservable()
+            .filter { it }
+            .map { item }
+    }
+
+/**
+ * Wraps current object to Maybe
+ */
+fun <T : Any> T?.toMaybe(): Maybe<T> =
+    if (this == null) {
+        Maybe.empty()
+    } else {
+        Maybe.just(this)
+    }
+
+/**
+ * Returns first element of list wrapped in Maybe or empty
+ */
+fun <T : Any> Single<List<T>>.maybeFirst(): Maybe<T> =
+    flatMapMaybe { it.firstOrNull().toMaybe() }
+
+/**
+ * Returns first element of list
+ */
+fun <T : Any> Single<List<T>>.first(): Single<T> =
+    map { it.first() }

domain-rx/src/main/java/ru/nobird/android/domain/rx/RxExtensions.kt

@@ -0,0 +1,17 @@
+package ru.nobird.android.domain.rx
+
+import org.junit.Test
+
+import org.junit.Assert.*
+
+/**
+ * Example local unit test, which will execute on the development machine (host).
+ *
+ * See [testing documentation](http://d.android.com/tools/testing).
+ */
+class ExampleUnitTest {
+    @Test
+    fun addition_isCorrect() {
+        assertEquals(4, 2 + 2)
+    }
+}