Observable<Long> values1 = Observable.interval(1000, TimeUnit.MILLISECONDS);
    values1.subscribe(
        v -> {
            System.out.println("Received 1: " + v + ", Thread: " + Thread.currentThread().getName());
        },
        e -> System.out.println("Error: " + e),
        () -> System.out.println("Completed")
    );

    Observable<Long> values2 = Observable.interval(1000, TimeUnit.MILLISECONDS);
    values2.subscribe(
        v -> {
            System.out.println("Received 2: " + v + ", Thread: " + Thread.currentThread().getName());
        },
        e -> System.out.println("Error: " + e),
        () -> System.out.println("Completed")
    );

    values1.subscribe(
            v -> {
                System.out.println("Received 3: " + v + ", Thread: " + Thread.currentThread().getName());
            },
            e -> System.out.println("Error: " + e),
            () -> System.out.println("Completed")
        );

    System.in.read();

Received 1: 0, Thread: RxComputationThreadPool-1
Received 3: 0, Thread: RxComputationThreadPool-3
Received 2: 0, Thread: RxComputationThreadPool-2
Received 1: 1, Thread: RxComputationThreadPool-1
Received 2: 1, Thread: RxComputationThreadPool-2
Received 3: 1, Thread: RxComputationThreadPool-3
...