Listen on all channels!

This commit is contained in:
Nico Schottelius 2016-11-02 17:55:52 +01:00
parent 3ae889d5a2
commit e25389db0d

View file

@ -18,9 +18,10 @@ def to_nodered(provider, data):
ws.close() ws.close()
def wait_for_pkg(conns): def wait_for_pkg(conns):
if select.select(conns,[],[]) == ([],[],[]):
print("Select error") readable, writable, exceptional = select.select(conns,[],[])
else:
for conn in readable:
conn.poll() conn.poll()
while conn.notifies: while conn.notifies:
notify = conn.notifies.pop(0) notify = conn.notifies.pop(0)