package Ġxyz . magenta ize . dynamic data . cache . internal Ċ Ċ 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 . dis pos ables . Disposable Ċ import Ġxyz . magenta ize . dynamic data . cache . Change Set Ċ import Ġxyz . magenta ize . dynamic data . cache . dispose Many Ċ import Ġxyz . magenta ize . dynamic data . cache . transform Ċ import Ġxyz . magenta ize . dynamic data . kernel . Observable Ex Ċ import Ġxyz . magenta ize . dynamic data . kernel . subscribe By Ċ Ċ internal Ġclass ĠSubscribe Many < K , ĠV >( ĊĠĠĠ Ġprivate Ġval Ġ_ source : ĠObservable < Change Set < K , ĠV >>, ĊĠĠĠ Ġprivate Ġval Ġ_ factory : Ġ( K , ĠV ) Ġ-> ĠDis posable Ċ ) Ġ{ ĊĠĠĠ Ġconstructor ( source : ĠObservable < Change Set < K , ĠV >>, Ġfactory : Ġ( V ) Ġ-> ĠDis posable ) Ġ: ĊĠĠĠĠĠĠĠĠĠĠĠ Ġthis ( source , Ġ{ Ġ_, Ġv Ġ-> Ġfactory ( v ) Ġ}) ĊĊĠĠĠ Ġfun Ġrun (): ĠObservable < Change Set < K , ĠV >> Ġ= ĊĠĠĠĠĠĠĠ ĠObservable Ex . create Ġ{ Ġemitter Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġshared Ġ= Ġ_ source . publish () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġsub Ġ= Ġshared ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. transform (_ factory ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. dispose Many () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe () ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġreturn @ create ĠComposite Disposable ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsub , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġshared . subscribe By ( emitter ), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġshared . connect () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠĠĠĠĠ Ġ} Ċ }