Add spawn to process

malcolm/core/process.py

@@ -84,3 +84,10 @@ def create_queue(self):
         """
 
         return self.sync_factory.create_queue()
+
+    def spawn(self, function, *args, **kwargs):
+        """Calls SyncFactory.spawn()"""
+        spawned = self.sync_factory.spawn(function, *args, **kwargs)
+        self._other_spawned.append(spawned)
+        return spawned
+

tests/test_core/test_process.py

@@ -51,5 +51,13 @@ def test_error(self):
         p.log_exception.assert_called_once_with("Exception while handling %s",
                                                 "<to_dict>")
 
+    def test_spawned_adds_to_other_spawned(self):
+        s = MagicMock()
+        p = Process("proc", s)
+        spawned = p.spawn(callable, "fred", a=4)
+        self.assertEqual(spawned, s.spawn.return_value)
+        self.assertEqual(p._other_spawned, [spawned])
+        s.spawn.assert_called_once_with(callable, "fred", a=4)
+
 if __name__ == "__main__":
     unittest.main(verbosity=2)