package Ġcom . software hut . sh repository Ċ Ċ import Ġcom . software hut . sh repository . domain . storage . Empty Web Reactive Storage Ċ import Ġio . reactivex . Observer Ċ import Ġio . reactivex . dis pos ables . Disposable Ċ import Ġorg . junit . Assert Ċ import Ġorg . junit . Before Ċ import Ġorg . junit . Test Ċ Ċ class ĠEmpty Web Reactive Storage Test Ġ{ ĊĊĠĠĠ Ġprivate Ġlateinit Ġvar ĠtestData : ĠTest Data ĊĊĠĠĠ Ġprivate Ġlateinit Ġvar Ġstorage : ĠEmpty Web Reactive Storage < TestData > ĊĊĠĠĠ Ġ@ Before ĊĠĠĠ Ġfun Ġbefore Test () Ġ{ ĊĠĠĠĠĠĠĠ ĠtestData Ġ= Ġcreate Zero Id TestData () ĊĠĠĠĠĠĠĠ Ġstorage Ġ= ĠEmpty Web Reactive Storage () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġread Stream _ with Zero Id _ does Not Return Any Items () Ġ{ ĊĠĠĠĠĠĠĠ Ġstorage . read Stream ( testData . id . toString ()). subscribe ( object Ġ: ĠObserver < TestData > Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun ĠonComplete () Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġon Subscribe ( d : ĠDis posable ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun Ġon Next ( t : ĠTest Data ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠAssert . fail () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġoverride Ġfun ĠonError ( e : ĠThrowable ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠAssert . fail () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ Ġ}) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġread Stream _ with Zero Id _ does Not Throw () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġstorage Ġ= ĠEmpty Web Reactive Storage < TestData >() ĊĠĠĠĠĠĠĠ Ġtry Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġstorage . read Stream ( testData . id . toString ()) ĊĠĠĠĠĠĠĠ Ġ} Ġcatch Ġ( ex : ĠException ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠAssert . fail () ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate Ġfun Ġcreate Zero Id TestData () Ġ= ĠTest Data ( 0 ) ĊĊĠĠĠ Ġdata Ġclass ĠTest Data ( val Ġid : ĠLong ) Ċ }