Skip to content

Commit 67826da

Browse files
author
AnkitDroidGit
committed
Added Combine Latest operator
1 parent 04fb540 commit 67826da

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

app/src/main/java/com/freeankit/rxjava2samples/ui/operators/combiningOperators/CombineLatestOperatorActivity.kt

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@ import io.reactivex.Observable
99
import io.reactivex.Observer
1010
import io.reactivex.android.schedulers.AndroidSchedulers
1111
import io.reactivex.disposables.Disposable
12-
import io.reactivex.functions.BiFunction
1312
import kotlinx.android.synthetic.main.activity_example_operator.*
1413

1514
/**
@@ -27,11 +26,12 @@ class CombineLatestOperatorActivity : AppCompatActivity() {
2726
val builder = StringBuilder()
2827
//combine two observables
2928
//notice the sizes of Observables and the output
30-
Observable
31-
.combineLatest(
29+
30+
31+
Observable.combineLatest(
3232
getBoyNames(),
3333
getRollNumber(),
34-
BiFunction { s, integer -> s + " -> " + integer })
34+
{ s, i -> s + " -> " + i })
3535
.observeOn(AndroidSchedulers.mainThread())
3636
.subscribe(object : Observer<String> {
3737
internal lateinit var d: Disposable

0 commit comments

Comments
 (0)