package Ġplay ground Ċ Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . schedul ers . Test Scheduler Ċ import Ġjava . util . concurrent . TimeUnit ĊĊ Ċ /** Ċ Ġ* Ġhttps :// github . com / Reactive X / Rx Java / wiki / Observable - Utility - Operators Ċ Ġ*/ Ċ Ċ class ĠDelay Subscription Exercise Ġ{ ĊĊĠĠĠ Ġfun Ġdelay _ subscription ( test Scheduler : ĠTest Scheduler ) Ġ= ĠObservable ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. range ( 1 , Ġ 3 ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. delay Subscription ( 1 , ĠTimeUnit . SECONDS , Ġtest Scheduler ) ĊĊĠĠĠ Ġfun Ġdelay _ subscription _ till _ an _ observable _ em its ( test Scheduler : ĠTest Scheduler ) Ġ= ĊĠĠĠĠĠĠĠĠĠĠĠ ĠObservable ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. range ( 1 , Ġ 3 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. delay Subscription ( Observable . empty < Any >(). delay ( 1 , ĠTimeUnit . SECONDS , Ġtest Scheduler )) ĊĊĠĠĠ Ġfun Ġdelay _ subscription _ till _ an _ observable _ em its ( de layer : ĠObservable < Any >) Ġ= ĊĠĠĠĠĠĠĠĠĠĠĠ ĠObservable ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. range ( 1 , Ġ 3 ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. delay Subscription ( de layer ) Ċ }