package Ġxyz . magenta ize . dynamic data . list . internal Ċ Ċ import Ġxyz . magenta ize . dynamic data . kernel . subscribe By Ċ import Ġxyz . magenta ize . dynamic data . list . Change Set Ċ import Ġxyz . magenta ize . dynamic data . list . Source List Ċ import Ġxyz . magenta ize . dynamic data . list . clear Ċ import Ġxyz . magenta ize . dynamic data . list . populate Into Ċ import Ġio . reactivex . rx java 3 . core . Observable Ċ import Ġio . reactivex . rx java 3 . dis pos ables . Composite Disposable Ċ import Ġio . reactivex . rx java 3 . internal . functions . Functions Ċ import Ġxyz . magenta ize . dynamic data . kernel . Observable Ex Ċ Ċ internal Ġclass ĠSwitch < T >( ĊĠĠĠ Ġprivate Ġvar Ġ_ source : ĠObservable < Observable < Change Set < T >>> Ċ ) Ġ{ ĊĠĠĠ Ġfun Ġrun (): ĠObservable < Change Set < T >> Ġ= ĊĠĠĠĠĠĠĠ ĠObservable Ex . create Ġ{ Ġemitter Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġdest Ġ= ĠSource List < T >() ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġpop ulator Ġ= Ġ_ source ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. do On Each Ġ{ Ġdest . clear () Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. switch Map ( Functions . identity ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. populate Into ( dest ) ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġpublisher Ġ= Ġdest . connect (). subscribe By ( emitter ) ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġreturn @ create ĠComposite Disposable ( dest , Ġpop ulator , Ġpublisher ) ĊĠĠĠĠĠĠĠ Ġ} Ċ } Ċ