A threaded event handler class.
Definition at line 157 of file __init__.py.
◆ __init__()
| def homeassistant.components.watson_iot.WatsonIOTThread.__init__ |
( |
|
self, |
|
|
|
hass, |
|
|
|
gateway, |
|
|
|
event_to_json |
|
) |
| |
◆ _event_listener()
| def homeassistant.components.watson_iot.WatsonIOTThread._event_listener |
( |
|
self, |
|
|
|
event |
|
) |
| |
|
private |
Listen for new messages on the bus and queue them for Watson IoT.
Definition at line 172 of file __init__.py.
◆ block_till_done()
| def homeassistant.components.watson_iot.WatsonIOTThread.block_till_done |
( |
|
self | ) |
|
Block till all events processed.
Definition at line 226 of file __init__.py.
◆ get_events_json()
| def homeassistant.components.watson_iot.WatsonIOTThread.get_events_json |
( |
|
self | ) |
|
Return an event formatted for writing.
Definition at line 177 of file __init__.py.
◆ run()
| def homeassistant.components.watson_iot.WatsonIOTThread.run |
( |
|
self | ) |
|
◆ write_to_watson()
| def homeassistant.components.watson_iot.WatsonIOTThread.write_to_watson |
( |
|
self, |
|
|
|
events |
|
) |
| |
Write preprocessed events to watson.
Definition at line 194 of file __init__.py.
◆ event_to_json
| homeassistant.components.watson_iot.WatsonIOTThread.event_to_json |
◆ gateway
| homeassistant.components.watson_iot.WatsonIOTThread.gateway |
◆ queue
| homeassistant.components.watson_iot.WatsonIOTThread.queue |
◆ shutdown
| homeassistant.components.watson_iot.WatsonIOTThread.shutdown |
◆ write_errors
| homeassistant.components.watson_iot.WatsonIOTThread.write_errors |
The documentation for this class was generated from the following file: