package Ġl k . spac ew a . boilerplate . data . remote Ċ Ċ import Ġcom . ap ol log raph ql . apollo . A pol lo Call Ċ import Ġcom . ap ol log raph ql . apollo . A pol lo Query Watcher Ċ import Ġcom . ap ol log raph ql . apollo . A pol lo Subscription Call Ċ import Ġcom . ap ol log raph ql . apollo . api . Response Ċ import Ġcom . ap ol log raph ql . apollo . rx 3 . Rx 3 A pol lo Ċ import Ġio . reactivex . rx java 3 . core . Flow able Ċ import Ġio . reactivex . rx java 3 . core . Observable Ċ import Ġjavax . annotation . Nonnull Ċ Ċ /** Ċ Ġ* ĠWrapper Ġto ĠRx 2 A pol lo Ġstatic Ġmethods Ġto Ġimprove Ġtest ability Ċ Ġ*/ Ċ class ĠApollo Rx Helper Ġ{ ĊĠĠĠ Ġfun Ġ< T > Ġfrom ( watcher : ĠApollo Subscription Call < T >): ĠFlow able < Response < T >> Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠRx 3 A pol lo . from ( watcher ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġ< T > Ġfrom ( watcher : ĠApollo Query Watcher < T >): ĠObservable < Response < T >> Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠRx 3 A pol lo . from ( watcher ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġ< T > Ġfrom ( call : ĠApollo Call < T >): ĠObservable < Response < T >> Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠRx 3 A pol lo . from ( call ) ĊĠĠĠ Ġ} Ċ }