Add deferred_call_delay property, default to 0.3

test/jmclient/test_wallet_rpc.py

@@ -171,6 +171,9 @@ class WalletRPCTestBaseFB(WalletRPCTestBase):
 class TrialTestWRPC_WS(WalletRPCTestBase, unittest.TestCase):
     """ class for testing websocket subscriptions/events etc.
     """
+    # The number of seconds to wait before calling the function. (type: float or int )
+    deferred_call_delay = 0.3
+
     def test_notif(self):
         # simulate the daemon already having created
         # a valid token (which it usually does when
@@ -180,7 +183,7 @@ def test_notif(self):
             "ws://127.0.0.1:"+str(self.wss_port))
         self.client_factory.protocol = ClientTProtocol
         self.client_connector = connectWS(self.client_factory)
-        d = task.deferLater(reactor, 0.1, self.fire_tx_notif)
+        d = task.deferLater(reactor, self.deferred_call_delay, self.fire_tx_notif)
         # create a small delay between the instruction to send
         # the notification, and the checking of its receipt,
         # otherwise the client will be queried before the notification
@@ -190,7 +193,7 @@ def test_notif(self):
         return d
 
     def wait_to_receive(self, res):
-        d = task.deferLater(reactor, 0.1, self.checkNotifs)
+        d = task.deferLater(reactor, self.deferred_call_delay, self.checkNotifs)
         return d
 
     def checkNotifs(self):

test/jmclient/test_websocket.py

@@ -63,6 +63,8 @@ class WebsocketTestBase(object):
     """
     # the port for the ws (auto)
     wss_port = None
+    # The number of seconds to wait before calling the function. (type: float or int )
+    deferred_call_delay = 0.3
 
     def setUp(self):
         if self.wss_port is None:
@@ -83,7 +85,7 @@ def do_test(self):
         self.client_factory.protocol = ClientTProtocol
         # keep track of the connector object so we can close it manually:
         self.client_connector = connectWS(self.client_factory)
-        d = task.deferLater(reactor, 0.1, self.fire_tx_notif)
+        d = task.deferLater(reactor, self.deferred_call_delay, self.fire_tx_notif)
         # create a small delay between the instruction to send
         # the notification, and the checking of its receipt,
         # otherwise the client will be queried before the notification
@@ -92,7 +94,7 @@ def do_test(self):
         return d
 
     def wait_to_receive(self, res):
-        d = task.deferLater(reactor, 0.1, self.checkNotifs)
+        d = task.deferLater(reactor, self.deferred_call_delay, self.checkNotifs)
         return d
 
     def checkNotifs(self):