package Ġplay ground Ċ Ċ import Ġio . reactivex . subjects . Publish Subject Ċ import Ġorg . junit . Test Ċ Ċ /* Ċ https :// rx mar bles . com /# with Latest From Ċ Ġ*/ Ċ Ċ class ĠWith Latest From DoesNot Wait Test Ġ{ ĊĊ ĉ @ Test Ċ ĉ fun Ġ` once Ġthe Ġemission Ġhappens Ġit Ġdoes Ġnot Ġwait Ġfor Ġthe Ġother Ġsources , Ġif Ġthey Ġare Ġnot Ġavailable Ġthen Ġit Ġdoes Ġnot Ġcall Ġthe Ġcombin er `() Ġ{ Ċĉ ĉ val Ġsource 1 Ġ= ĠPublish Subject . create < Int >() Ċĉ ĉ val Ġsource 2 Ġ= ĠPublish Subject . create < Int >() Ċĉ ĉ val Ġsource 3 Ġ= ĠPublish Subject . create < Int >() ĊĊĉ ĉ val Ġtest Observer Ġ= Ġsource 1 . with Latest From ( source 2 , Ġsource 3 , Ġ{ Ġt 1 , Ġt 2 , Ġt 3 Ġ-> Ċĉĉ ĉ t 1 Ġ+ Ġt 2 Ġ+ Ġt 3 Ċĉ ĉ }). test () ĊĊĉ ĉ val ĠSOURCE 1 Ġ= Ġ 1 Ċĉ ĉ val ĠSOURCE 2 Ġ= Ġ 2 Ċĉ ĉ val ĠSOURCE 3 Ġ= Ġ 3 Ċĉ ĉ val ĠSOURCE 4 Ġ= Ġ 4 ĊĊĉ ĉ source 1 . onNext ( SOURCE 1 ) Ċĉ ĉ test Observer . assert No Values () Ċĉ ĉ source 2 . onNext ( SOURCE 2 ) Ċĉ ĉ test Observer . assert No Values () Ċĉ ĉ source 3 . onNext ( SOURCE 3 ) Ċĉ ĉ test Observer . assert No Values () ĊĊĉ ĉ source 1 . onNext ( SOURCE 4 ) Ċĉ ĉ test Observer . assert Value ( SOURCE 4 Ġ+ ĠSOURCE 2 Ġ+ ĠSOURCE 3 ) Ċ ĉ } Ċ }