Skip to content

Commit adf6187

Browse files
committed
fix callback and wrapper
1 parent 47ed5da commit adf6187

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

pysyncobj/pysyncobj3/syncobj.py

+3-2
Original file line numberDiff line numberDiff line change
@@ -848,9 +848,10 @@ def rep_cb(res, err):
848848
local.error = err
849849
local.event.set()
850850
if kwargs.get('_doApply', False):
851-
replicated(func)(self, *args, **kwargs)
851+
return replicated(func)(self, *args, **kwargs)
852852
else:
853-
replicated(func)(self, callback = rep_cb, *args, **kwargs)
853+
kwargs["callback"] = rep_cb
854+
replicated(func)(self, *args, **kwargs)
854855
res = local.event.wait(timeout = timeout)
855856
if not res:
856857
raise SyncObjException('Timeout')

pysyncobj/syncobj.py

+3-2
Original file line numberDiff line numberDiff line change
@@ -845,9 +845,10 @@ def rep_cb(res, err):
845845
local.error = err
846846
local.event.set()
847847
if kwargs.get('_doApply', False):
848-
replicated(func)(self, *args, **kwargs)
848+
return replicated(func)(self, *args, **kwargs)
849849
else:
850-
replicated(func)(self, callback = rep_cb, *args, **kwargs)
850+
kwargs["callback"] = rep_cb
851+
replicated(func)(self, *args, **kwargs)
851852
res = local.event.wait(timeout = timeout)
852853
if not res:
853854
raise SyncObjException('Timeout')

0 commit comments

Comments
 (0)