package Ġcom . kes co . ad k . rx Ċ Ċ import Ġandroid . os . Handler Ċ import Ġandroid . os . Looper Ċ import Ġrx . Scheduler Ċ import Ġjava . util . concurrent . Executors Ċ Ċ /** Ċ Ġ* Ġä¿®æĶ¹ èĩª [ Rx Android ]( https :// github . com / Reactive X / Rx Android ) Ċ Ġ* Ċ Ġ* Ġ åĽłä¸º æĪĳ è§ī å¾Ĺ ä¸įéľĢè¦ģ åĨĻ å¾Ĺ éĤ£ä¹Ī è´Ł è´£ ï¼Į åĲĮæĹ¶ åĬł è¿Ľ èĩªå·± ä¿®æĶ¹ çļĦ åĲİåı° å¼ĤæŃ¥ çº¿ç¨ĭ æ±ł Scheduler Ċ Ġ*/ Ċ public Ġobject ĠAndroid Rx Plugin Ġ{ ĊĠĠĠ Ġprivate Ġval Ġ_ main Thread Scheduler Ġ= ĠHandler Scheduler ( Handler ( Looper . get Main Looper ())) ĊĠĠĠ Ġprivate Ġval Ġ_ worker Thread Scheduler Ġ= ĠWork Thread Scheduler ( Executors . new Scheduled ThreadPool ( Runtime . get Runtime (). available Processors ())) ĊĊĠĠĠ Ġval Ġmain Thread : ĠScheduler ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġ_ main Thread Scheduler ĊĊĠĠĠ Ġval Ġworker Thread : ĠScheduler ĊĠĠĠĠĠĠĠ Ġget () Ġ= Ġ_ worker Thread Scheduler Ċ } Ċ