package Ġcom . r ab t man . ac g schedule . mvp . model Ċ Ċ import Ġandroid . text . TextUtils Ċ import Ġcom . fc ann izz aro . js oup . annotations . JP Ċ import Ġcom . r ab t man . ac g schedule . mvp . contract . Schedule Video Contract Ċ import Ġcom . r ab t man . ac g schedule . mvp . model . js oup . Schedule Video Ċ import Ġcom . r ab t man . common . base . mvp . BaseModel Ċ import Ġcom . r ab t man . common . di . scope . Activity Scope Ċ import Ġcom . r ab t man . common . integration . I Repository Manager Ċ import Ġio . reactivex . Back pressure Strategy Ċ import Ġio . reactivex . Flow able Ċ import Ġorg . js oup . J soup Ċ import Ġorg . js oup . nodes . Element Ċ import Ġjavax . inject . Inject Ċ Ċ /** Ċ Ġ* Ġ@ author ĠR ab t man Ċ Ġ*/ Ċ @ Activity Scope Ċ class ĠSchedule Video Model Ġ@ Inject Ġconstructor ( repository Manager : ĠI Repository Manager ) Ġ: ĠBase Model ( repository Manager ), ĠSchedule Video Contract . Model Ġ{ ĊĠĠĠ Ġoverride Ġfun Ġget Schedule Video ( url : ĠString ): ĠFlow able < Schedule Video > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠFlow able . create ({ Ġe Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġhtml : ĠElement ? Ġ= ĠJ soup . connect ( url ). get () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġif Ġ( html Ġ== Ġnull ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġe . onError ( Throwable (" element Ġhtml Ġis Ġnull ")) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} Ġelse Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġschedule Video Ġ= ĠJ P . from ( html , ĠSchedule Video :: class . java ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġif Ġ(! TextUtils . isEmpty ( schedule Video . video Html )) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġschedule Video . video Url Ġ= Ġ" http :// tup . yh dm . tv /? m = 1 & vid =" Ġ+ Ġschedule Video . video Url ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġe . onNext ( schedule Video ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġe . onComplete () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ}, ĠBack pressure Strategy . BUFFER ) ĊĠĠĠ Ġ} Ċ }