package Ġcom . y ann is . base lib . net Ċ Ċ import Ġcom . y ann is . base lib . base . Operator Error Next Func Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . Observable Source Ċ import Ġio . reactivex . Observable Transformer Ċ import Ġio . reactivex . android . schedul ers . Android Schedulers Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ Ċ /** Ċ Ġ* Ġ å°ģè£ħ Rx Java ä¸ŃçļĦ " ä¸ŃéĹ´ æķ°æį® å¤ĦçĲĨ " Ċ Ġ* Ċ Ġ* Ġ@ author Ġ Ġw en j ia . Ch eng Ġ Ġc wj 1 7 1 4 @ 1 6 3 . com Ċ Ġ* Ġ@ date ĠĠĠĠ 2 0 2 0 / 6 / 8 Ċ Ġ*/ Ċ class ĠRun On < T > Ġ: ĠObservable Transformer < T , ĠT > Ġ{ ĊĠĠĠ Ġoverride Ġfun Ġapply ( upstream : ĠObservable < T >): ĠObservable Source < T > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġupstream ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ// Ġ ç»Łä¸Ģ å¤ĦçĲĨ Ġ ç½ĳç»ľ è¯·æ±Ĥ ä¸ŃçļĦ å¼Ĥå¸¸ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. onError Resume Next ( Operator Error Next Func < T >()) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ// Ġ å¤ĦçĲĨ çº¿ç¨ĭ éĹ´ çļĦ åĪĩæį¢ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe On ( Schedulers . io ()) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. observe On ( Android Schedulers . main Thread ()) ĊĠĠĠ Ġ} Ċ }