package Ġcom . minder a . s ke leto id . rx Ċ Ċ import Ġio . reactivex . Scheduler Ċ import Ġio . reactivex . android . plugins . Rx Android Plugins Ċ import Ġio . reactivex . internal . schedul ers . Executor Scheduler Ċ import Ġio . reactivex . plugins . Rx Java Plugins Ċ import Ġorg . junit . After Ċ import Ġorg . junit . Before Ċ import Ġjava . util . concurrent . Executor Ċ Ċ abstract Ġclass ĠBase Rx Test Ġ{ ĊĊĠĠĠ Ġ@ Before ĊĠĠĠ Ġopen Ġfun ĠsetUp () Ġ{ ĊĠĠĠĠĠĠĠ Ġsetup Rx Schedulers () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ After ĊĠĠĠ Ġopen Ġfun ĠtearDown Test () Ġ{ ĊĠĠĠĠĠĠĠ ĠRx Java Plugins . reset () ĊĠĠĠ Ġ} Ċ } Ċ Ċ private Ġfun Ġsetup Rx Schedulers () Ġ{ ĊĠĠĠ ĠRx Java Plugins . reset () ĊĊĠĠĠ Ġval Ġimmediate Ġ= Ġobject Ġ: ĠScheduler () Ġ{ ĊĠĠĠĠĠĠĠ Ġoverride Ġfun Ġcreate Worker (): ĠWorker Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreturn ĠExecutor Scheduler . Executor Worker ( Executor Ġ{ Ġit . run () Ġ}, Ġtrue ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ ĠRx Java Plugins . set Init Io Scheduler Handler Ġ{ Ġimmediate Ġ} ĊĠĠĠ ĠRx Java Plugins . set Init Computation Scheduler Handler Ġ{ Ġimmediate Ġ} ĊĠĠĠ ĠRx Java Plugins . set Init New Thread Scheduler Handler Ġ{ Ġimmediate Ġ} ĊĠĠĠ ĠRx Java Plugins . set Init Single Scheduler Handler Ġ{ Ġimmediate Ġ} ĊĠĠĠ ĠRx Android Plugins . set Init MainThread Scheduler Handler Ġ{ Ġimmediate Ġ} Ċ Ċ } Ċ