Merge dont stop

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        Button button = findViewById(R.id.btn);

        Observable.merge(obs1, obs2)
                .subscribe(data -> Log.d(TAG, String.valueOf(data)));
    }

    Observable<String> obs1 = Observable.interval(1, TimeUnit.SECONDS)
            .map(data -> "obs1: " + data);

    Observable obs2 =
            Observable.just(1, 2, 3, 4, 5)
                    .delay(1, TimeUnit.SECONDS)
                    .filter(data -> data < 5)
                    .map(data -> "obs2: " + data)
                    .doOnComplete(() -> Log.d(TAG, "done"));

D/MainActivity: obs1: 0
                obs2: 1
                obs2: 2
                obs2: 3
D/MainActivity: obs2: 4
                done
D/MainActivity: obs1: 1
D/MainActivity: obs1: 2
D/MainActivity: obs1: 3
D/MainActivity: obs1: 4