package Ġchapter 0 4 . create Ċ Ċ import Ġcommon . Common Utils Ċ import Ġcommon . Log Ċ import Ġio . reactivex . Observable Ċ import Ġjava . util . concurrent . TimeUnit Ċ Ċ class ĠInterval Example Ġ{ ĊĠĠĠ Ġfun Ġprint Number () Ġ{ ĊĠĠĠĠĠĠĠ ĠCommon Utils . start () ĊĠĠĠĠĠĠĠ Ġval Ġsource Ġ= ĠObservable . interval ( 1 0 0 , ĠTimeUnit . MILLISECONDS ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ Ġdata Ġ-> Ġ( data Ġ+ Ġ 1 ) Ġ* Ġ 1 0 0 Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. take ( 5 ) ĊĠĠĠĠĠĠĠ Ġsource . subscribe Ġ{ Ġdata Ġ-> ĠLog . it ( data ) Ġ} ĊĠĠĠĠĠĠĠ ĠCommon Utils . sleep ( 1 0 0 0 ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġnon Initial Delay () Ġ{ ĊĠĠĠĠĠĠĠ ĠCommon Utils . start () ĊĠĠĠĠĠĠĠ Ġval Ġsource Ġ= ĠObservable . interval ( 0 , Ġ 1 0 0 , ĠTimeUnit . MILLISECONDS ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ Ġdata Ġ-> Ġdata Ġ+ Ġ 1 0 0 Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. take ( 5 ) ĊĠĠĠĠĠĠĠ Ġsource . subscribe Ġ{ Ġdata Ġ-> ĠLog . it ( data ) Ġ} ĊĠĠĠĠĠĠĠ ĠCommon Utils . sleep ( 1 0 0 0 ) ĊĠĠĠ Ġ} Ċ } Ċ Ċ fun Ġmain () Ġ{ ĊĠĠĠ Ġval Ġdemo Ġ= ĠInterval Example () ĊĠĠĠ Ġdemo . print Number () ĊĠĠĠ Ġdemo . non Initial Delay () Ċ }