package Ġmod als Ċ Ċ import Ġio . reactivex . rx java 3 . ob servers . Test Observer Ċ import Ġorg . junit . jupiter . api . BeforeEach Ċ import Ġorg . junit . jupiter . api . Test Ċ import Ġpo jo . Chat Ċ Ċ internal Ġclass ĠRepository Impl Test Ġ{ ĊĊĠĠĠ Ġprivate Ġlateinit Ġvar Ġrepository : ĠRepository ĊĊĠĠĠ Ġ@ BeforeEach ĊĠĠĠ Ġfun Ġsetup () Ġ{ ĊĠĠĠĠĠĠĠ Ġrepository Ġ= ĠRepository Impl () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġget Chat Messages () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġtest Observer : ĠTest Observer < Chat > Ġ= Ġrepository . get Chat Messages ( false ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. test () ĊĊĠĠĠĠĠĠĠ Ġval Ġmessage Ġ= Ġ" Many Ġtimes " ĊĠĠĠĠĠĠĠ Ġval Ġchat Ġ= ĠChat ( CHAT _ ID , Ġmessage , ĠCH AT _ STATUS , ĠCH AT _ RAT ING ) ĊĊĠĠĠĠĠĠĠ Ġtest Observer . assert Complete () ĊĠĠĠĠĠĠĠ Ġtest Observer . assert No Errors () ĊĠĠĠĠĠĠĠ Ġtest Observer . assert Value Count ( 1 ) Ġ// Ġvalue Count Ġis Ġthe Ġnumber Ġof Ġemission s ĊĠĠĠĠĠĠĠ Ġtest Observer . assert Value ( chat ) Ġ// ĠIf Ġthere Ġare Ġmultiple Ġemission s , Ġuse Ġassert Values () ĊĠĠĠĠĠĠĠ Ġ// ĠC le ans Ġup Ġresources , Ġnot Ġcomp uls ory , Ġbut ĠSTR ON GL Y Ġrecommended ĊĠĠĠĠĠĠĠ Ġtest Observer . dispose () ĊĠĠĠ Ġ} Ċ }