diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2018-05-21 03:20:52 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2018-05-21 03:20:52 +0200 |
| commit | 231ef3f2e2acac86f74bde75122a989d3822d93d (patch) | |
| tree | 49e2dede5e26cd4603e57f7dffe3bd7a575d0562 /rpc/rpc.py | |
| parent | e970193abced6a6967c8781fa9b7eb27b8bcb3b6 (diff) | |
activate fn
Diffstat (limited to 'rpc/rpc.py')
| -rw-r--r-- | rpc/rpc.py | 4 |
1 files changed, 3 insertions, 1 deletions
@@ -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): |
