summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJules Laplace <julescarbon@gmail.com>2018-05-21 03:20:52 +0200
committerJules Laplace <julescarbon@gmail.com>2018-05-21 03:20:52 +0200
commit231ef3f2e2acac86f74bde75122a989d3822d93d (patch)
tree49e2dede5e26cd4603e57f7dffe3bd7a575d0562
parente970193abced6a6967c8781fa9b7eb27b8bcb3b6 (diff)
activate fn
-rw-r--r--rpc/rpc.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/rpc/rpc.py b/rpc/rpc.py
index 6c0442d..b8b4cb5 100644
--- a/rpc/rpc.py
+++ b/rpc/rpc.py
@@ -10,10 +10,11 @@ from PIL import Image
load_dotenv(find_dotenv())
class CortexRPC(object):
- def __init__(self, get_fn, set_fn):
+ def __init__(self, get_fn, set_fn, ready_fn):
super().__init__()
self._get_fn = get_fn
self._set_fn = set_fn
+ self._ready_fn = ready_fn
self.working = False
self.connect()
@@ -22,6 +23,7 @@ class CortexRPC(object):
self.rpc = zerorpc.Server(self)
self.rpc.bind('tcp://127.0.0.1:' + os.getenv('RPC_PORT'))
gevent.spawn(self.connected)
+ gevent.spawn(self._ready_fn)
self.rpc.run()
def connected(self):