Merge pull request #4 from eigr-labs/dev/venkatesh

invokes a request from client after server starts

Author: sleipnir

example/spawn_example.py

@@ -3,15 +3,14 @@
 Licensed under the Apache License, Version 2.0.
 """
 from spawn.sdk import Spawn
-from example.joe import JoeActor 
+from example.joe import JoeActor
 from example.domain.domain_pb2 import Reply, Request
 
-if __name__ == '__main__':
-    #request = Request()
-    #request.language = "erlang"
-    #Spawn.invoke("joe", "setLanguage", request, Reply)
+if __name__ == "__main__":
+    request = Request()
+    request.language = "erlang"
+    # Spawn.invoke("joe", "setLanguage", request, Reply)
 
-    Spawn()\
-        .port('8091')\
-        .register_actor(JoeActor.entity)\
-        .start()
+    spawn = Spawn()
+    spawn.port("8091").register_actor(JoeActor.entity).start()
+    spawn.invoke("vijay", "setLanguage", request, Reply)

spawn/sdk.py

@@ -65,7 +65,7 @@ def start(self):
         """Start the user function and HTTP Server."""
         address = "{}:{}".format(self.__host, self.__port)
 
-        server = threading.Thread(target=self.__start_server, daemon=True, args=(action_handler,))
+        server = threading.Thread(target=lambda: self.__start_server(action_handler))
         logging.info("Starting Spawn on address %s", address)
         try:
             server.start()
@@ -75,12 +75,14 @@ def start(self):
         except IOError as e:
             logging.error("Error on start Spawn %s", e.__cause__)
 
-        while True:
-            time.sleep(1)
-
     def __register(self, actors: List[ActorEntity]):
         self.__actorController.register(actors)
 
     def __start_server(self, handler):
-        self.__app.register_blueprint(handler, url_prefix='/api/v1')
-        self.__app.run(host=self.__host, port=self.__port, use_reloader=False, debug=self.__is_debug_enable)
+        self.__app.register_blueprint(handler, url_prefix="/api/v1")
+        self.__app.run(
+            host=self.__host,
+            port=self.__port,
+            use_reloader=False,
+            debug=self.__is_debug_enable,
+        )