package Ġqs os . lib . net service Ċ Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . android . schedul ers . Android Schedulers Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ import Ġjava . util . concurrent . TimeUnit Ċ Ċ /** Ċ Ġ* Ġ@ author Ġ åįİ æ¸ħ æĿ ¾ Ċ Ġ* Ġ@ doc Ġä½¿çĶ¨ åľºæĻ¯ ï¼ļ ĠJ UNIT Ġ è¿Ľè¡Į æµĭè¯ķ æĹ¶ æ¨¡ æĭŁ ç½ĳç»ľ è¯·æ±Ĥ è¿ĶåĽŀ Ċ Ġ*/ Ċ object ĠObservable Decorator Ġ{ ĊĊĠĠĠ Ġfun Ġ< T > Ġdecor ate ( observable : ĠObservable < T >): ĠObservable < T > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġif Ġ( Api Engine . is UnitTest ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ// Ġå½ĵåīį çº¿ç¨ĭ åĲĮæŃ¥ æī§è¡Į ĊĠĠĠĠĠĠĠĠĠĠĠ Ġobservable . subscribe On ( Schedulers . tr amp oline ()). observe On ( Schedulers . tr amp oline ()) ĊĠĠĠĠĠĠĠ Ġ} Ġelse Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġobservable . subscribe On ( Schedulers . new Thread ()). observe On ( Android Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. delay ( 2 , ĠTimeUnit . SECONDS , ĠAndroid Schedulers . main Thread ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ