package Ġcom . example . daniel . my application Ċ Ċ import Ġandroid . util . Log Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . Observer Ċ import Ġio . reactivex . dis pos ables . Disposable Ċ import Ġio . reactivex . schedul ers . Schedulers Ċ import Ġjunit . framework . Assert . assertEquals Ċ import Ġorg . junit . Test Ċ Ċ import Ġorg . junit . Assert .* Ċ import Ġjava . sql . Time Ċ import Ġjava . util . concurrent . TimeUnit Ċ Ċ /** Ċ Ġ* ĠExample Ġlocal Ġunit Ġtest , Ġwhich Ġwill Ġexecute Ġon Ġthe Ġdevelopment Ġmachine Ġ( host ). Ċ Ġ* Ċ Ġ* ĠSee Ġ[ testing Ġdocumentation ]( http :// d . android . com / tools / testing ). Ċ Ġ*/ Ċ class ĠExample UnitTest Ġ{ ĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġaddition _ is Correct () Ġ{ ĊĠĠĠĠĠĠĠ ĠassertEquals ( 4 , Ġ 2 Ġ+ Ġ 2 ) Ċ /* ĠĠĠĠĠĠĠ ĠObservable . just (" test "). start With (" xxx ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. start With (" 2 3 3 ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. start With (" 3 5 1 ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe { System . out . println ( it )} */ ĊĠĠĠĠĠĠĠ Ġval Ġobservable Ġ= ĠObservable . just ( 1 ). delay ( 2 0 0 0 , TimeUnit . MILLISECONDS ) ĊĠĠĠĠĠĠĠ ĠSystem . out . println (" start ") ĊĠĠĠĠĠĠĠ ĠObservable . just (" Test ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. start With (" xxx ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. start With (" 2 3 3 ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. start With (" 3 5 1 ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. delay Subscription ( observable ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe { System . out . println ( it )} ĊĠĠĠĠĠĠĠ ĠThread . sleep ( 5 0 0 0 ) ĊĠĠĠĠĠĠĠ ĠSystem . out . println (" end ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġ Ġtest Hex (){ ĊĠĠĠĠĠĠĠ Ġval Ġtt : Long Ġ= Ġ 0 xaa ffffff ĊĠĠĠĠĠĠĠ Ġval Ġtt 2 : Int Ġ= Ġ 0 xaa ffffff . toInt () ĊĠĠĠĠĠĠĠ ĠSystem . out . print ("$ tt Ġ: Ġ$ tt 2 ") ĊĠĠĠ Ġ} ĊĠĠĠ Ġ@ Test ĊĠĠ Ġfun Ġtest Range (){ ĊĠĠĠĠĠĠĠ Ġval Ġtmp Ġ= Ġ 0 ĊĠĠĠĠĠĠĠ Ġwhen ( tmp ){ ĊĠĠĠĠĠĠĠĠĠĠĠĠ 0 Ġ-> Ġ{ System . out . print (" tmp Ġ$ tmp ")} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġin Ġ 0 .. 1 0 Ġ-> { System . out . print (" 0 .. 1 0 Ġtmp Ġ$ tmp ")} ĊĠĠĠĠĠĠĠ Ġ} ĊĊĊĊĠĠĠ Ġ} Ċ } Ċ