X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;ds=sidebyside;f=actions.py;fp=actions.py;h=db2a7774e531fc0783690a3c2a6c205d9c39841a;hb=6075497ad81cd8ac5515cc71eaf83964a079a955;hp=e25c82b75ebe5f32d38fd258b7df0fce40de220b;hpb=ce646c5d477b8cea8d1d69c435d686624d9c2e15;p=quix0rs-apt-p2p.git

diff --git a/actions.py b/actions.py
index e25c82b..db2a777 100644
--- a/actions.py
+++ b/actions.py
@@ -87,7 +87,7 @@ class FindNode(ActionBase):
         if self.outstanding == 0:
             ## all done!!
             self.finished=1
-            reactor.callFromThread(self.callback, l[:K])
+            reactor.callLater(0, self.callback, l[:K])
     
     def makeMsgFailed(self, node):
         def defaultGotNodes(err, self=self, node=node):
@@ -150,7 +150,7 @@ class GetValue(FindNode):
             z = len(dict['values'])
             v = filter(None, map(x, dict['values']))
             if(len(v)):
-                reactor.callFromThread(self.callback, v)
+                reactor.callLater(0, self.callback, v)
         self.schedule()
         
     ## get value
@@ -179,7 +179,7 @@ class GetValue(FindNode):
         if self.outstanding == 0:
             ## all done, didn't find it!!
             self.finished=1
-            reactor.callFromThread(self.callback,[])
+            reactor.callLater(0, self.callback,[])
 
     ## get value
     def goWithNodes(self, nodes, found=None):