package Ġcom . lyft . d roid conn yc 2 0 1 7 . pu zz lers . rx java . medium Ċ Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . rx kotlin . with Latest From Ċ import Ġio . reactivex . subjects . Behavior Subject Ċ import Ġio . reactivex . subjects . Publish Subject Ċ import Ġorg . junit . Test Ċ Ċ class ĠMedium Rx P uzz ler 1 Ġ{ ĊĊĠĠĠ Ġ// ĠWhat Ġwill Ġbe Ġprinted Ġand Ġwhy ? ĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġp uzz ler () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġupstream Ġ= ĠBehavior Subject . create < Int >() ĊĠĠĠĠĠĠĠ Ġupstream . onNext ( 0 ) ĊĊĠĠĠĠĠĠĠ Ġupstream ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. what Does This Extension Do () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe Ġ{ Ġvalue Ġ-> Ġprintln ( value ) Ġ} ĊĊĠĠĠĠĠĠĠ Ġupstream . onNext ( 1 ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ// ĠWhat Ġwill Ġbe Ġprinted Ġand Ġwhy ? ĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġis It Different Question Mark () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġupstream Ġ= ĠPublish Subject . create < Int >() ĊĠĠĠĠĠĠĠ Ġupstream . onNext ( 0 ) ĊĊĠĠĠĠĠĠĠ Ġupstream ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. what Does This Extension Do () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe Ġ{ Ġvalue Ġ-> Ġprintln ( value ) Ġ} ĊĊĠĠĠĠĠĠĠ Ġupstream . onNext ( 1 ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġ< T > ĠObservable < T >. what Does This Extension Do (): ĠObservable < T > Ġ= ĠObservable Ġ// ĠCan Ġyou Ġimprove Ġthis Ġfunction ? ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. just ( 1 ) Ġ// ĠWhat Ġif Ġyou Ġuse Ġjust (- 1 )? ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. with Latest From ( this ) Ġ{ Ġinteger , Ġt Ġ-> Ġt Ġ} Ċ } Ċ