java - How to use CompositeDisposable of RxJava 2? -

examples on how use compositedisposable or disposable in rxjava2. in rxjava 1, there compositesubscription, not present in rxjava2, there compositedisposable in rxjava2. how use compositedisposable or disposable in rxjava2.

private final compositedisposable disposables = new compositedisposable();   // adding observable disposable disposables.add(sampleobservable()                 .subscribeon(schedulers.io())                 .observeon(androidschedulers.mainthread())                 .subscribewith(new disposableobserver<string>() {                     @override                     public void oncomplete() {                     }                      @override                     public void onerror(throwable e) {                     }                      @override                     public void onnext(string value) {                     }                 }));      static observable<string> sampleobservable() {         return observable.defer(new callable<observablesource<? extends string>>() {             @override             public observablesource<? extends string> call() throws exception {                 // long running operation                 systemclock.sleep(2000);                 return observable.just("one", "two", "three", "four", "five");             }         });     }                   // using clear clear all, can accept new disposable disposables.clear();  // using dispose clear , set isdisposed = true, not accept new disposable disposables.dispose();  

i have create sample project demonstrate use of rxjava2. here can find sample project - rxjava2-android-samples