Sample_of_rx_switch_map_with_interrupt_2.kt

private val mDisposablesOnCreate = CompositeDisposable()

// Activity onCreate().
override fun onCreate() {    
    // Long computation operation.
    mDisposablesOnCreate.add(
        // Share button.
        onClickShare()
            .switchMap { _ ->
                // First, switchMap convert the click to an action observable.
                // Whenever a new click is received, switchMap interrupt and
                // kills the existing ongoing observable and replace it with
                // the new one.
                // Second, subscribe to the action observable with a cancel
                // throttle where the takeUntil self terminates and also kill
                // the action observable when a cancel signal is received.
                toShareAction()
                    .takeUntil(mCancelSrc)
            }
            .subscribe { _ ->
                Log.d("xyz", "all finished!")
            })

    // Cancel signal.
    mDisposablesOnCreate.add(
        onClickCancel()
            .subscribe { _ ->
                mCancelSrc.onNext(0)
            })
}

// Activity onDestroy()
override fun onDestroy() {
    mDisposablesOnCreate.clear()

// "Share" button observable.
fun onClickShare(): Observable<Any> { ... }
// "Cancel" button observable.
fun onClickCancel(): Observable<Any> { ... }