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