package Ġcom . bad oo . mv ic ore . scheduler Ċ Ċ import Ġio . reactivex . Scheduler Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ import Ġjava . util . concurrent . Executors Ċ Ċ class ĠMV IC ore Schedulers Ġ{ ĊĠĠĠ Ġcompanion Ġobject Ġ{ ĊĠĠĠĠĠĠĠ Ġinternal Ġvar Ġlegacy Scheduler : ĠScheduler ? Ġ= Ġnull ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġset ĊĊĠĠĠĠĠĠĠ Ġinternal Ġvar Ġobserver Scheduler : ĠScheduler ? Ġ= Ġnull ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġset ĊĊĠĠĠĠĠĠĠ Ġprivate Ġval Ġstandard Main Scheduler Ġ= ĠS chedulers . from ( Executors . new Fixed ThreadPool ( 1 )) ĊĠĠĠĠĠĠĠ Ġvar Ġmain Ġ= Ġstandard Main Scheduler ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprivate Ġset ĊĊĠĠĠĠĠĠĠ Ġfun Ġscheduler ( scheduler : ĠScheduler ?) Ġ= ĊĠĠĠĠĠĠĠĠĠĠĠ Ġscheduler Ġ?: Ġlegacy Scheduler Ġ?: Ġmain ĊĊĠĠĠĠĠĠĠ Ġfun Ġobserver Scheduler ( scheduler : ĠScheduler ?) Ġ= ĊĠĠĠĠĠĠĠĠĠĠĠ Ġscheduler Ġ?: Ġobserver Scheduler Ġ?: Ġmain ĊĊĠĠĠĠĠĠĠ Ġfun Ġset New Main Scheduler ( scheduler : ĠScheduler ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġmain Ġ= Ġscheduler ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġfun Ġset New Legacy Scheduler ( scheduler : ĠScheduler ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġlegacy Scheduler Ġ= Ġscheduler ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġfun Ġset New Observer Scheduler ( scheduler : ĠScheduler ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġobserver Scheduler Ġ= Ġscheduler ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġfun Ġreset () Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġmain Ġ= Ġstandard Main Scheduler ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ