gistfile1.txt

class HookTest {

    @Test
    fun testChangeHooks() {
        val first = Hook()
        RxJavaPlugins.getInstance().registerObservableExecutionHook(first)

        Observable.just(null).subscribe {  }

        assertThat(first.invoked, `is`(true))

        RxJavaPlugins.getInstance().reset()
        val second = Hook()
        RxJavaPlugins.getInstance().registerObservableExecutionHook(second)

        Observable.just(null).subscribe {  }

        assertThat(second.invoked, `is`(true))
    }

    class Hook : RxJavaObservableExecutionHook() {

        @Volatile
        var invoked = false

        override fun <T : Any?> onSubscribeStart(observableInstance: Observable<out T>?, onSubscribe: Observable.OnSubscribe<T>?): Observable.OnSubscribe<T>? {
            invoked = true
            return super.onSubscribeStart(observableInstance, onSubscribe)
        }
    }
}