1 from .client
import AllWatcherFacade
as BaseAllWatcher
2 from .client
import ClientFacade
5 class AllWatcher(BaseAllWatcher
):
6 async def rpc(self
, msg
):
7 if not hasattr(self
, 'Id'):
8 client
= ClientFacade()
9 client
.connect(self
.connection
)
11 result
= await client
.WatchAll()
12 self
.Id
= result
.watcher_id
15 return await super(AllWatcher
, self
).rpc(msg
)