diff options
| author | Aaron Perley <aaron.perley@gmail.com> | 2016-10-11 02:03:49 -0400 |
|---|---|---|
| committer | Aaron Perley <aaron.perley@gmail.com> | 2016-10-11 02:03:49 -0400 |
| commit | 2d37dd487f0571ce94a0e4e966931dd6697d685f (patch) | |
| tree | 3a55e17552c4c5cb2a26f23c4613d0d7ca0dce28 /show.py | |
| parent | 198dcfc6f43724a3240496259e2bcda8b6bf6e8d (diff) | |
| download | bridge-2d37dd487f0571ce94a0e4e966931dd6697d685f.tar.zst | |
Add event passing between webapp and show
Diffstat (limited to 'show.py')
| -rw-r--r-- | show.py | 15 |
1 files changed, 14 insertions, 1 deletions
@@ -1,5 +1,6 @@ from __future__ import division, print_function import time +import Queue class Clock(object): def __init__(self): @@ -18,10 +19,12 @@ class Clock(object): class Show(object): - def __init__(self, bridge): + def __init__(self, bridge, send_queue, recv_queue): self.bridge = bridge self.clock = Clock() self.running = True + self.send_queue = send_queue + self.recv_queue = recv_queue self.init() def run(self, framerate=40): @@ -30,6 +33,16 @@ class Show(object): self.bridge.update() self.clock.tick(framerate) + def send_event(self, event_name, data=None): + self.send_queue.put((event_name, data)) + + def recv_event(self): + try: + msg = self.recv_queue.get_nowait() + return msg + except Queue.Empty: + return None + def init(self): """Override me""" raise NotImplementedError |
