summaryrefslogtreecommitdiff
path: root/rpc/rpc.py
diff options
context:
space:
mode:
authorJules Laplace <julescarbon@gmail.com>2018-05-21 03:59:48 +0200
committerJules Laplace <julescarbon@gmail.com>2018-05-21 03:59:48 +0200
commit5c88e0c90fba33e72e6c243ffbdc55251d83375f (patch)
tree8693f283a24b442121a5485dbe2dabc48efa0862 /rpc/rpc.py
parentfd8a167543c6f68436f0b80a4085e9d8e6bde6d0 (diff)
un rato
Diffstat (limited to 'rpc/rpc.py')
-rw-r--r--rpc/rpc.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/rpc/rpc.py b/rpc/rpc.py
index 51f8feb..cc2336e 100644
--- a/rpc/rpc.py
+++ b/rpc/rpc.py
@@ -12,8 +12,8 @@ load_dotenv(find_dotenv())
class CortexRPC(object):
def __init__(self, get_fn, set_fn, ready_fn):
super().__init__()
- self._get_fn = get_fn
- self._set_fn = set_fn
+ self._get_fn = staticmethod(get_fn)
+ self._set_fn = staticmethod(set_fn)
self.working = False
self.connect(ready_fn)
@@ -22,7 +22,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(ready_fn)
+ gevent.spawn(lambda: ready_fn(self))
self.rpc.run()
def connected(self):