Skip to content

Commit 0c81ac7

Browse files
author
Ramakrishna
committed
Added Concat Operator usage.
1 parent ae0b0b1 commit 0c81ac7

File tree

1 file changed

+28
-0
lines changed

1 file changed

+28
-0
lines changed
Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
package com.example.reactiveprogrammingusingrxjava2._operators;
2+
3+
import android.support.v7.app.AppCompatActivity;
4+
5+
import com.example.reactiveprogrammingusingrxjava2.BaseActivity;
6+
7+
import io.reactivex.Observable;
8+
import io.reactivex.functions.Consumer;
9+
10+
public class Rx_d_ConcatOperator extends BaseActivity {
11+
12+
@Override
13+
protected void onResume() {
14+
super.onResume();
15+
16+
Observable aSeriesObservable = Observable.just("A1","A2","A3","A4","A5","A6","A7", "A8", "A9", "A10");
17+
Observable bSeriesObservable = Observable.just("B1","B2","B3","B4","B5","B6","B7", "B8", "B9", "B10");
18+
19+
Observable
20+
.concat(bSeriesObservable, aSeriesObservable)
21+
.subscribe(new Consumer() {
22+
@Override
23+
public void accept(Object o) throws Exception {
24+
logMessage(o.toString()); //First gets all items from first observable passed to concat and then second observable items
25+
}
26+
});
27+
}
28+
}

0 commit comments

Comments
 (0)