|
def | __init__ (self) |
|
def | call_later (self, delay, callback) |
|
def | call_soon (self, callback) |
|
def | create_server (self, proto, hostname, port) |
|
def | create_task (self, coro, cb=None) |
|
def | run (self) |
|
def | run_coro_and_wait (self, coro) |
|
def | run_until_complete (self, coro) |
|
def | start (self) |
|
def | stop (self) |
|
run an asyncio loop in a thread
Definition at line 121 of file utils.py.
def opcua.common.utils.ThreadLoop.__init__ |
( |
|
self | ) |
|
def opcua.common.utils.ThreadLoop._create_task |
( |
|
self, |
|
|
|
future, |
|
|
|
coro, |
|
|
|
cb = None |
|
) |
| |
|
private |
def opcua.common.utils.ThreadLoop._run_until_complete |
( |
|
self, |
|
|
|
future, |
|
|
|
coro |
|
) |
| |
|
private |
def opcua.common.utils.ThreadLoop.call_later |
( |
|
self, |
|
|
|
delay, |
|
|
|
callback |
|
) |
| |
threadsafe call_later from asyncio
Definition at line 158 of file utils.py.
def opcua.common.utils.ThreadLoop.call_soon |
( |
|
self, |
|
|
|
callback |
|
) |
| |
def opcua.common.utils.ThreadLoop.create_server |
( |
|
self, |
|
|
|
proto, |
|
|
|
hostname, |
|
|
|
port |
|
) |
| |
def opcua.common.utils.ThreadLoop.create_task |
( |
|
self, |
|
|
|
coro, |
|
|
|
cb = None |
|
) |
| |
threadsafe create_task from asyncio
Definition at line 172 of file utils.py.
def opcua.common.utils.ThreadLoop.run |
( |
|
self | ) |
|
def opcua.common.utils.ThreadLoop.run_coro_and_wait |
( |
|
self, |
|
|
|
coro |
|
) |
| |
def opcua.common.utils.ThreadLoop.run_until_complete |
( |
|
self, |
|
|
|
coro |
|
) |
| |
threadsafe run_until_completed from asyncio
Definition at line 195 of file utils.py.
def opcua.common.utils.ThreadLoop.start |
( |
|
self | ) |
|
def opcua.common.utils.ThreadLoop.stop |
( |
|
self | ) |
|
stop subscription loop, thus the subscription thread
Definition at line 149 of file utils.py.
opcua.common.utils.ThreadLoop._cond |
|
private |
opcua.common.utils.ThreadLoop.logger |
opcua.common.utils.ThreadLoop.loop |
The documentation for this class was generated from the following file: