Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class MainActivity extends AppCompatActivity {
- private final String TAG = this.getClass().getSimpleName();
- private CompositeDisposable mCompositeDisposable = new CompositeDisposable();
- private Presenter mPresenter;
- Button button1;
- Button button2;
- @Override
- protected void onCreate(Bundle savedInstanceState) {
- super.onCreate(savedInstanceState);
- setContentView(R.layout.activity_main);
- mPresenter = new Presenter();
- button1 = findViewById(R.id.btn_1);
- button2 = findViewById(R.id.btn_2);
- Observable.merge(getObs1(), getObs2())
- .switchMap(this::getObservable)
- .subscribe(data -> Log.d(TAG, (String) data));
- }
- public Observable<Integer> getObs1() {
- return RxView.clicks(button1)
- .map(view -> 1);
- }
- public Observable<Integer> getObs2() {
- return RxView.clicks(button2)
- .map(view -> 2);
- }
- Observable<String> getObservable(int id) {
- return Observable.interval(1, TimeUnit.SECONDS)
- .map(data -> "Obs" + String.valueOf(id) + ":" + data);
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement