-
Notifications
You must be signed in to change notification settings - Fork 0
/
FlatMapOperatorActivity.kt
77 lines (61 loc) · 2.49 KB
/
FlatMapOperatorActivity.kt
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
package neo.rxkotlin.playground.view.operators
import android.os.Bundle
import android.support.v7.app.AppCompatActivity
import android.util.Log
import io.reactivex.Observable
import io.reactivex.Observer
import io.reactivex.disposables.Disposable
import kotlinx.android.synthetic.main.activity_example.*
import neo.rxkotlin.playground.R
import neo.rxkotlin.playground.utility.appendText
/**
* @author Naveen T P
* @since 31/08/18
*/
class FlatMapOperatorActivity : AppCompatActivity() {
private val TAG = FlatMapOperatorActivity::class.java.simpleName
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_example)
displayInitialData()
btn.setOnClickListener { doSomething() }
}
private fun doSomething() {
getObservable()
.flatMap { integer -> getAddObservable(integer, integer) }
.flatMap { integer -> getMultiplyObservable(integer, integer) }
.subscribe(getObserver())
}
private fun getObservable(): Observable<Int> {
return Observable.just(1, 2, 3, 4, 5)
}
private fun getAddObservable(first: Int, second: Int): Observable<Int> {
return Observable.just(first + second)
}
private fun getMultiplyObservable(first: Int, second: Int): Observable<Int> {
return Observable.just(first * second)
}
private fun getObserver(): Observer<Int> {
return object : Observer<Int> {
override fun onSubscribe(d: Disposable) {
Log.d(TAG, "onSubscribe: ${d.isDisposed}")
}
override fun onNext(t: Int) {
tv_result.appendText("onNext: $t")
}
override fun onComplete() {
tv_result.appendText("onComplete")
}
override fun onError(e: Throwable) {
tv_result.appendText("onError: ${e.message}")
}
}
}
private fun displayInitialData() {
tv_explanation.appendText("The FlatMap operator transform the items emitted by an " +
"Observable into Observables, then flatten the emissions from those into a single Observable")
tv_explanation.appendText("Initial items are: 1, 2, 3, 4, 5")
tv_explanation.appendText("Output: Each emitted item is added by itself and multiplied by itself and emitted as output..")
tv_explanation.appendText("Example: Emitted value (1) => (1+1 = 2) => (2*2 = 4) => 4")
}
}