dispose

dispose.java

        CompositeDisposable disposable = new CompositeDisposable();
        disposable.add(
                Observable.just("hi").delay(1000, TimeUnit.MILLISECONDS).subscribe(data -> System.out.println("hi"))
        );

        disposable.dispose();

        disposable.add(
                Observable.just("hi").delay(1000, TimeUnit.MILLISECONDS).subscribe(data -> System.out.println("hi"))
        );
        disposable.dispose();