package Ġcom . inst ac art . formula . stop watch Ċ Ċ import Ġcom . google . common . truth . Truth . assertThat Ċ import Ġcom . inst ac art . formula . Cancel able Ċ import Ġcom . inst ac art . formula . samples . network state . Network State Ċ import Ġcom . inst ac art . formula . samples . network state . Network State Formula Ċ import Ġcom . inst ac art . formula . samples . network state . Network State Stream Ċ import Ġcom . inst ac art . formula . test . test Ċ import Ġorg . junit . Test Ċ Ċ class ĠNetwork State Formula Test Ġ{ ĊĊĠĠĠ Ġ@ Test Ġfun Ġoffline () Ġ{ ĊĠĠĠĠĠĠĠ Ġformula ( is Online Ġ= Ġfalse ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. test ( Unit ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. output Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠassertThat ( status ). isEqualTo (" Network Ġstate : ĠOFF LINE ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test Ġfun Ġconnected () Ġ{ ĊĠĠĠĠĠĠĠ Ġformula ( is Online Ġ= Ġtrue ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. test ( Unit ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. output Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠassertThat ( status ). isEqualTo (" Network Ġstate : ĠCONNECT ED ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate Ġfun Ġformula ( is Online : ĠBoolean ) Ġ= ĠNetwork State Formula ( network State Stream ( is Online )) ĊĊĠĠĠ Ġprivate Ġfun Ġnetwork State Stream ( is Online : ĠBoolean ) Ġ= Ġobject Ġ: ĠNetwork State Stream Ġ{ ĊĠĠĠĠĠĠĠ Ġoverride Ġfun Ġstart ( send : Ġ( Network State ) Ġ-> ĠUnit ): ĠCancel able ? Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ// ĠAdding Ġextra Ġevents Ġto Ġensure Ġthat Ġit Ġhandles Ġmultiple Ġupdates ĊĠĠĠĠĠĠĠĠĠĠĠ Ġsend ( Network State ( false )) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġsend ( Network State ( true )) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġsend ( Network State ( is Online )) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreturn Ġnull ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ