Hey, I want to test method which internally uses...

# android

[dzakens]

Hey,

I want to test method which internally uses PublishSubject. I have set up schedulers :

override fun apply(base: Statement, description: Description): Statement {
return object : Statement() {

override fun evaluate() {
RxJavaPlugins.setInitIoSchedulerHandler { _ -> immediate }
RxJavaPlugins.setInitComputationSchedulerHandler { _ -> immediate }
RxJavaPlugins.setInitNewThreadSchedulerHandler { _ -> immediate }
RxJavaPlugins.setInitSingleSchedulerHandler { _ -> immediate }
RxAndroidPlugins.setInitMainThreadSchedulerHandler { _ -> immediate }

try {
base.evaluate()
} finally {
RxJavaPlugins.reset()
RxAndroidPlugins.reset()
}
}
}
}

From unknown reason when subject.onNext is called , observable onNext is not called but onComplete is fired. This situation happens only in my unit test. Have anyone similar problem ?