package Ġxyz . fc amp bell . rx play services . we arable Ċ Ċ import Ġandroid . content . Context Ċ import Ġandroid . net . Uri Ċ import Ġcom . google . android . gms . common . api . Status Ċ import Ġcom . google . android . gms . we arable . Message Api Ċ import Ġcom . google . android . gms . we arable . W ear able Ċ import Ġio . reactivex . Observable Ċ import Ġxyz . fc amp bell . rx play services . base . ApiClient Descriptor Ċ import Ġxyz . fc amp bell . rx play services . base . Api Descriptor Ċ import Ġxyz . fc amp bell . rx play services . base . Rx Play Services Api Ċ Ċ /** Ċ Ġ* ĠWrap s Ġ[ W ear able . Message Api ] Ċ Ġ*/ Ċ @ Suppress (" unused ") Ċ class ĠRx Message Api ( ĊĠĠĠĠĠĠĠ ĠapiClient Descriptor : ĠApi Client Descriptor , ĊĠĠĠĠĠĠĠ Ġwe arable Options : ĠW ear able . W ear able Options Ċ ) Ġ: ĠRx Play Services Api < Message Api , ĠW ear able . W ear able Options >( ĊĠĠĠĠĠĠĠ ĠapiClient Descriptor , ĊĠĠĠĠĠĠĠ ĠApi Descriptor ( W ear able . API , ĠW ear able . Message Api , Ġwe arable Options ) Ċ ) Ġ{ ĊĠĠĠ Ġconstructor ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġcontext : ĠContext , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġwe arable Options : ĠW ear able . W ear able Options ĊĠĠĠ Ġ) Ġ: Ġthis ( ApiClient Descriptor ( context ), Ġwe arable Options ) ĊĊĠĠĠ Ġfun ĠsendMessage ( nodeId : ĠString , Ġpath : ĠString , Ġdata : ĠByteArray ): ĠObservable < Message Api . SendMessage Result > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġfrom Pending Result Ġ{ ĠsendMessage ( it , ĠnodeId , Ġpath , Ġdata ) Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġadd Listener ( listener : ĠMessage Api . Message Listener ): ĠObservable < Status > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġfrom Pending Result Ġ{ Ġadd Listener ( it , Ġlistener ) Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġadd Listener ( listener : ĠMessage Api . Message Listener , Ġuri : ĠUri , Ġfilter Type : ĠInt ): ĠObservable < Status > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġfrom Pending Result Ġ{ Ġadd Listener ( it , Ġlistener , Ġuri , Ġfilter Type ) Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġremove Listener ( listener : ĠMessage Api . Message Listener ): ĠObservable < Status > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġfrom Pending Result Ġ{ Ġremove Listener ( it , Ġlistener ) Ġ} ĊĠĠĠ Ġ} Ċ }