|
@@ -289,12 +289,12 @@ class globCL(GCLMixin):
|
289
|
289
|
p("_run_persistent_loop3:",self,a,kw)
|
290
|
290
|
loop = asyncio.new_event_loop()
|
291
|
291
|
self.run_persistent_loop = nop
|
292
|
|
- loop.run_forever()
|
293
|
292
|
self.rman.persistent_loop_cb()
|
294
|
293
|
loop.create_task(self.persistent_loop())
|
295
|
294
|
# loop.create_task(self.persistent_fast_cb_loop())
|
296
|
|
- loop.create_task(self.persistent_fast_cb_loop_min_timeout())
|
297
|
295
|
self.loop = loop
|
|
296
|
+ loop.run_until_complete(self.persistent_fast_cb_loop_min_timeout())
|
|
297
|
+ # loop.run_forever()
|
298
|
298
|
|
299
|
299
|
def _run_persistent_loop(self,*a,**kw):
|
300
|
300
|
p("_run_persistent_loop:",self,a,kw)
|