|
|
@@ -121,6 +121,7 @@ class globCL():
|
|
121
|
121
|
self.cbs_once = []
|
|
122
|
122
|
self.cbs_once_set = set()
|
|
123
|
123
|
self.cbs = {"fn1":fn1,"fn2x":nop}
|
|
|
124
|
+ self.timeout = 1
|
|
124
|
125
|
pass
|
|
125
|
126
|
async def persistent_loop(self,*a,**kw):
|
|
126
|
127
|
while 1:
|
|
|
@@ -183,7 +184,7 @@ class globCL():
|
|
183
|
184
|
|
|
184
|
185
|
|
|
185
|
186
|
|
|
186
|
|
- await asyncio.sleep(cls.timeout)
|
|
|
187
|
+ await asyncio.sleep(self.timeout)
|
|
187
|
188
|
def _run_persistent_loop(self,*a,**kw):
|
|
188
|
189
|
p("_run_persistent_loop:")
|
|
189
|
190
|
loop = asyncio.get_event_loop()
|