Added Retry operator

Author: AnkitDroidGit

README.md

@@ -103,7 +103,6 @@ Adding more operator examples
 
 
 
-
 # RxBinding
 
 Rx is powerful because we can compose transformations. What that means is that we can have reusable, safe and more functional code that simply plugs into your code.
@@ -122,7 +121,7 @@ Consider the following rules that we want for our email addresses
 * [RxLoginScreenActivity](https://github.com/AnkitDroidGit/RxKotlinOperators-Android/blob/master/RxOperators/src/main/java/com/freeankit/rxkotlinoperators/ui/RxBinding/RxLoginScreenActivity.kt) - Login Screen using RxBinding
 
 
-# Pagination And Lazyloading using RxKotlin
+# Pagination And Lazy loading using RxKotlin
 
 
 ## Highlights :
@@ -131,7 +130,6 @@ Consider the following rules that we want for our email addresses
 
 
 
-
 ### Contact - Let's connect to learn together
 - [Twitter](https://twitter.com/KumarAnkitRKE)
 - [Github](https://github.com/AnkitDroidGit)

RxOperators/src/main/AndroidManifest.xml

@@ -54,6 +54,7 @@
         <activity android:name="com.freeankit.rxkotlinoperators.ui.RxOperators.combiningOperators.CombineLatestOperatorActivity" />
         <activity android:name=".ui.RxPagination.PaginationActivity" />
         <activity android:name=".ui.RxBinding.RxLoginScreenActivity" />
+        <activity android:name=".ui.RxOperators.errorHandlingOperators.RetryOperatorActivity" />
     </application>
 
 </manifest>

RxOperators/src/main/java/com/freeankit/rxkotlinoperators/ui/OperatorsActivity.kt

@@ -13,6 +13,7 @@ import com.freeankit.rxkotlinoperators.ui.RxOperators.connectableOperators.Repla
 import com.freeankit.rxkotlinoperators.ui.RxOperators.connectableOperators.ReplaySubjectOperatorActivity
 import com.freeankit.rxkotlinoperators.ui.RxOperators.creatingOperators.DeferOperatorActivity
 import com.freeankit.rxkotlinoperators.ui.RxOperators.creatingOperators.IntervalOperatorActivity
+import com.freeankit.rxkotlinoperators.ui.RxOperators.errorHandlingOperators.RetryOperatorActivity
 import com.freeankit.rxkotlinoperators.ui.RxOperators.filteringOperators.*
 import com.freeankit.rxkotlinoperators.ui.RxOperators.mathematicalOperators.ConcatOperatorActivity
 import com.freeankit.rxkotlinoperators.ui.RxOperators.mathematicalOperators.ReduceOperatorActivity
@@ -147,4 +148,8 @@ class OperatorsActivity : AppCompatActivity() {
     fun startDelayActivity(view: View) {
         startActivity(Intent(this@OperatorsActivity, DelayOperatorActivity::class.java))
     }
+
+    fun startRetryActivity(view: View) {
+        startActivity(Intent(this@OperatorsActivity, RetryOperatorActivity::class.java))
+    }
 }

RxOperators/src/main/java/com/freeankit/rxkotlinoperators/ui/RxOperators/errorHandlingOperators/RetryOperatorActivity.kt

@@ -0,0 +1,86 @@
+package com.freeankit.rxkotlinoperators.ui.RxOperators.errorHandlingOperators
+
+import android.os.Bundle
+import android.support.v7.app.AppCompatActivity
+import android.util.Log
+import com.freeankit.rxkotlinoperators.R
+import com.freeankit.rxkotlinoperators.utils.Constant
+import io.reactivex.Observable
+import io.reactivex.Observer
+import io.reactivex.android.schedulers.AndroidSchedulers
+import io.reactivex.disposables.Disposable
+import io.reactivex.schedulers.Schedulers
+import kotlinx.android.synthetic.main.activity_example_operator.*
+import java.util.concurrent.TimeUnit
+
+/**
+ * @author Ankit Kumar ([email protected]) on 22/04/2018 (MM/DD/YYYY)
+ */
+class RetryOperatorActivity : AppCompatActivity() {
+    override fun onCreate(savedInstanceState: Bundle?) {
+        super.onCreate(savedInstanceState)
+        setContentView(R.layout.activity_example_operator)
+
+        btn.setOnClickListener({ executeRetryOperator() })
+    }
+
+
+//    if a source Observable emits an error, resubscribe to it in the hopes that it will complete without error
+
+    private fun executeRetryOperator() {
+        getObservable()
+                .retry()
+//                .retryWhen(o -> o.delay(100, TimeUnit.MILLISECONDS))
+                .debounce(500, TimeUnit.MILLISECONDS)
+                // Run on a background thread
+                .subscribeOn(Schedulers.io())
+                // Be notified on the main thread
+                .observeOn(AndroidSchedulers.mainThread())
+                .subscribe(getObserver())
+    }
+
+    private fun getObservable(): Observable<Int> {
+        return Observable.create { emitter ->
+            // send events with simulated time wait
+            emitter.onNext(1) // skip
+            Thread.sleep(400)
+            emitter.onNext(2) // deliver
+            Thread.sleep(505)
+            emitter.onNext(3) // skip
+            Thread.sleep(100)
+            emitter.onNext(4) // deliver kj h ihioh
+            Thread.sleep(605) ///////////////
+            emitter.onNext(5) // deliver
+            Thread.sleep(510)
+            emitter.onComplete()
+        }
+    }
+
+
+    private fun getObserver(): Observer<Int> {
+        return object : Observer<Int> {
+            override fun onSubscribe(d: Disposable) {
+                Log.d(Constant().TAG, " onSubscribe : " + d.isDisposed)
+            }
+
+            override fun onNext(value: Int) {
+                textView.append(" onNext : value : $value")
+                textView.append(Constant().LINE_SEPARATOR)
+                Log.d(Constant().TAG, " onNext value : $value")
+            }
+
+            override fun onError(e: Throwable) {
+                textView.append(" onError : " + e.message)
+                textView.append(Constant().LINE_SEPARATOR)
+                Log.d(Constant().TAG, " onError : " + e.message)
+            }
+
+            override fun onComplete() {
+                textView.append(" onComplete")
+                textView.append(Constant().LINE_SEPARATOR)
+                Log.d(Constant().TAG, " onComplete")
+            }
+        }
+    }
+
+}

RxOperators/src/main/res/layout/activity_operators.xml

@@ -223,5 +223,12 @@
             android:onClick="startDelayActivity"
             android:text="@string/delay"
             android:textColor="@android:color/black" />
+
+        <Button
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:onClick="startRetryActivity"
+            android:text="@string/retry"
+            android:textColor="@android:color/black" />
     </LinearLayout>
 </ScrollView>

RxOperators/src/main/res/values/strings.xml

@@ -33,4 +33,5 @@
     <string name="delay">Delay</string>
     <string name="rxpagination">RxPagination</string>
     <string name="rxbinding">RxBinding</string>
+    <string name="retry">Retry</string>
 </resources>