Cancelling a observable

Code

    private val subscriptions = CompositeDisposable()

    /**
     * Cancelling single observable
     */
    fun cancelSingleObservableDemo() {
        val observable = Observable.never<Any>()

        observable.subscribeBy(
            onNext = {
                println("Result-> $it")
            },
            onError = {
                println("ErrorMessage-> ${it.localizedMessage}")
            },
            onComplete = {
                println("Emissions are complete")
            }
        ).addTo(subscriptions)
    }

    fun performCanceling(){
        if(!subscriptions.isDisposed){
            subscriptions.dispose()
        }
        val isDisposed = subscriptions.isDisposed
        println("Subscriptions disposed: ->$isDisposed")
    }

Output

Subscriptions disposed: ->true